[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13586969#comment-13586969 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 10:03 AM: --- Two producers(10.2.44.73,10.2.44.80) each pushes 500msg/4sec to server (10.11.146.197) The 2nd test done but with different error logs. Might be a memory issue? was (Author: tamilmaran): Two producers(10.2.44.73,10.2.44.80)each push 500msg/4sec to server(10.11.146.197) The 2nd test done but with different error logs. Might be a memory issue? > SocketException: Connection reset exception occurred in ActiveMQ for Bulk > message 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 >Priority: Blocker > Attachments: activemq.log, activemq.xml, SimulatorTC.rar, > Test2-activemq.log > > > I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And > a durable subscriber in server side but not sure about its speed to consume > all the messages in same rate as well as the producer. > But after an hour, 'Connection is already closed' error is logged on producer > side. > On ActiveMQ side, Following error has been logged. > 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. > Attached activeMQ config file and producer app(WAPSimulator) -- 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
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13586969#comment-13586969 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 9:51 AM: -- Two producers(10.2.44.73,10.2.44.80)each push 500msg/4sec to server(10.11.146.197) The 2nd test done but with different error logs. Might be a memory issue? was (Author: tamilmaran): Two producers(10.2.44.73,10.2.44.80)each push 500msg/4sec to server(10.11.146.197) The second test but with different error logs. Might be a memory issue? > SocketException: Connection reset exception occurred in ActiveMQ for Bulk > message 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 >Priority: Blocker > Attachments: activemq.log, activemq.xml, SimulatorTC.rar, > Test2-activemq.log > > > I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And > a durable subscriber in server side but not sure about its speed to consume > all the messages in same rate as well as the producer. > But after an hour, 'Connection is already closed' error is logged on producer > side. > On ActiveMQ side, Following error has been logged. > 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. > Attached activeMQ config file and producer app(WAPSimulator) -- 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
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13586886#comment-13586886 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 7:22 AM: -- At the time of testing, connectionInterruptedListener and connectionResumedListener were like below:- private void connectionInterruptedListener() { Logger.AddBebug("Broker Interrupted"); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } Now i changed it like below and started testing again:- private void connectionInterruptedListener() { Logger.AddBebug("Broker Interrupted"); this.firstConnectionAttemptFailed = true; } private void connectionResumedListener() { Logger.AddBebug("Broker Resumed"); if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); Logger.AddBebug("Broker Resumed and restarted"); } } was (Author: tamilmaran): At the time of testing, connectionInterruptedListener and connectionResumedListener were like below:- private void connectionInterruptedListener() { Logger.AddBebug("Broker Interrupted"); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } Now i changed it like below and started testing again:- private void connectionInterruptedListener() { Logger.AddBebug("Broker Interrupted"); this.firstConnectionAttemptFailed = true; } private void connectionResumedListener() { Logger.AddBebug("Broker Resumed"); if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); Logger.AddBebug("Broker Resumed and restarted"); } } > SocketException: Connection reset exception occurred in ActiveMQ for Bulk > message 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 >Priority: Blocker > Attachments: activemq.log, activemq.xml, SimulatorTC.rar > > > I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And > a durable subscriber in server side but not sure about its speed to consume > all the messages in same rate as well as the producer. > But after an hour, 'Connection is already closed' error is logged on producer > side. > On ActiveMQ side, Following error has been logged. > 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. > Attached activeMQ config file and producer app(WAPSimulator) -- 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
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13586886#comment-13586886 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 7:21 AM: -- At the time of testing, connectionInterruptedListener and connectionResumedListener were like below:- private void connectionInterruptedListener() { Logger.AddBebug("Broker Interrupted"); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } Now i changed it like below and started testing again:- private void connectionInterruptedListener() { Logger.AddBebug("Broker Interrupted"); this.firstConnectionAttemptFailed = true; } private void connectionResumedListener() { Logger.AddBebug("Broker Resumed"); if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); Logger.AddBebug("Broker Resumed and restarted"); } } was (Author: tamilmaran): At the time of testing, connectionInterruptedListener and connectionResumedListener are like below:- private void connectionInterruptedListener() { Logger.AddBebug("Broker Interrupted"); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } > SocketException: Connection reset exception occurred in ActiveMQ for Bulk > message 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 >Priority: Blocker > Attachments: activemq.log, activemq.xml, SimulatorTC.rar > > > I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And > a durable subscriber in server side but not sure about its speed to consume > all the messages in same rate as well as the producer. > But after an hour, 'Connection is already closed' error is logged on producer > side. > On ActiveMQ side, Following error has been logged. > 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. > Attached activeMQ config file and producer app(WAPSimulator) -- 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
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13586877#comment-13586877 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 6:57 AM: -- After setting the producer window size to Max,it seems running yesterday night. but when i see it in the morning,consumer is not getting any msg from producer i.e.,producer stopped publishing. Following is the producer log:- 2013-02-25 18:44:41,976: DEBUG – Broker Started 2013-02-25 18:44:41,992: DEBUG – Simulator started. 2013-02-25 18:44:42,429: DEBUG – Hello Request sent for SMS Casino ID: 194 2013-02-25 18:44:42,539: DEBUG – Hello Request sent for SMS Casino ID: 195 2013-02-25 18:44:44,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-25 18:44:45,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-26 06:20:10,070: DEBUG – Broker Interrupted was (Author: tamilmaran): After setting the producer window size to Max,it seems running yesterday night. but when i see it in the morning,consumer is not getting any msg from producer i.e.,producer stopped publishing. Following log is from Producer:- 2013-02-25 18:44:41,976: DEBUG – Broker Started 2013-02-25 18:44:41,992: DEBUG – Simulator started. 2013-02-25 18:44:42,429: DEBUG – Hello Request sent for SMS Casino ID: 194 2013-02-25 18:44:42,539: DEBUG – Hello Request sent for SMS Casino ID: 195 2013-02-25 18:44:44,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-25 18:44:45,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-26 06:20:10,070: DEBUG – Broker Interrupted > SocketException: Connection reset exception occurred in ActiveMQ for Bulk > message 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 >Priority: Blocker > Attachments: activemq.log, activemq.xml, SimulatorTC.rar > > > I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And > a durable subscriber in server side but not sure about its speed to consume > all the messages in same rate as well as the producer. > But after an hour, 'Connection is already closed' error is logged on producer > side. > On ActiveMQ side, Following error has been logged. > 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. > Attached activeMQ config file and producer app(WAPSimulator) -- 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
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13586869#comment-13586869 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 6:49 AM: -- Modified Bulk Message Producer was (Author: tamilmaran): Bulk Message Producer > SocketException: Connection reset exception occurred in ActiveMQ for Bulk > message 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 >Priority: Blocker > Attachments: activemq.log, activemq.xml, SimulatorTC.rar > > > I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And > a durable subscriber in server side but not sure about its speed to consume > all the messages in same rate as well as the producer. > But after an hour, 'Connection is already closed' error is logged on producer > side. > On ActiveMQ side, Following error has been logged. > 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. > Attached activeMQ config file and producer app(WAPSimulator) -- 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