activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tamilmaran (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
Date Tue, 26 Feb 2013 07:24:12 GMT

    [ 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

Mime
View raw message