You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Tamilmaran (JIRA)" <ji...@apache.org> on 2013/02/20 15:41:13 UTC
[jira] [Updated] (AMQ-4336) Connection reset exception occurred on
Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Tamilmaran updated AMQ-4336:
----------------------------
Description:
I have a Bulk MSG producer which sends 1000 messages for every 4 seconds.
But after an hour, Connection reset exception occurred for Bulk MSG producer:-
2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355
10.2.44.73-Bulk MSG producer IP
ActiveMQ is using File based cursor and producer control.
was:
I have a Bulk MSG producer which sends 1000 messages for every 4 seconds.
But after an hour, Connection reset exception occurred for Bulk MSG producer:-
2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355
10.2.44.73-Bulk MSG producer IP
ActiveMQ is using File based cursor and producer control.
ActiveMQ configuration:
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<value>file:${activemq.conf}/credentials.properties</value>
</property>
</bean>
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" offlineDurableSubscriberTimeout="21600000" offlineDurableSubscriberTaskSchedule="1800000">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">" producerFlowControl="false" memoryLimit="900mb">
<pendingSubscriberPolicy>
<vmCursor/>
</pendingSubscriberPolicy>
<pendingDurableSubscriberPolicy>
<fileDurableSubscriberCursor/>
</pendingDurableSubscriberPolicy>
</policyEntry>
<policyEntry queue=">" producerFlowControl="false" memoryLimit="20mb">
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<managementContext>
<managementContext createConnector="false"/>
</managementContext>
<persistenceAdapter>
<kahaDB ignoreMissingJournalfiles="true" directory="${activemq.data}/kahadb"/>
</persistenceAdapter>
<systemUsage>
<systemUsage sendFailIfNoSpaceAfterTimeout="15000">
<memoryUsage>
<memoryUsage limit="900 mb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="100 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="50 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<sslContext>
<sslContext keyStore="file:${activemq.conf}\broker.ks" keyStorePassword="HVObfvBd@zDo" trustStore="file:${activemq.conf}\client.ks" trustStorePassword="HVObfvBd@zDo"/>
</sslContext>
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
<transportConnector name="ssl" uri="ssl://0.0.0.0:61617"/>
<transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/>
<transportConnector name="stompssl" uri="stomp+ssl://0.0.0.0:61614"/>
</transportConnectors>
</broker>
<import resource="jetty.xml"/>
</beans>
> Connection reset exception occurred on Bulk msg producer
> --------------------------------------------------------
>
> Key: AMQ-4336
> URL: https://issues.apache.org/jira/browse/AMQ-4336
> Project: ActiveMQ
> Issue Type: Bug
> Environment: ActiveMQ 5.6,NMS,C#
> Reporter: Tamilmaran
> Attachments: activemq.xml
>
>
> I have a Bulk MSG producer which sends 1000 messages for every 4 seconds.
> But after an hour, Connection reset exception occurred for Bulk MSG producer:-
> 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355
> 10.2.44.73-Bulk MSG producer IP
> ActiveMQ is using File based cursor and producer control.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira