[
https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tamilmaran updated AMQ-4336:
----------------------------
Attachment: activemq.xml
> 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.
> 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>
--
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
