You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Rob Godfrey (JIRA)" <qp...@incubator.apache.org> on 2008/01/25 12:10:34 UTC

[jira] Commented: (QPID-761) Inifinte loop in Java Client failover

    [ https://issues.apache.org/jira/browse/QPID-761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12562441#action_12562441 ] 

Rob Godfrey commented on QPID-761:
----------------------------------

my test:

        AMQConnection con = new AMQConnection("tcp://127.0.0.1:5672?retries='0'", "guest", "guest", "test", "test");
        AMQTopic topic = new AMQTopic(con.getDefaultTopicExchangeName(), "MyTopic");
        con.start();
        for(int i = 0; i< 2000; i++)
        {
                TopicSession session1 = con.createTopicSession(false, AMQSession.AUTO_ACKNOWLEDGE);
                TopicSubscriber sub = session1.createDurableSubscriber(topic, "subscription0");
                TopicPublisher publisher = session1.createPublisher(topic);



                TextMessage tm = session1.createTextMessage("Hello");
                publisher.publish(tm);

                tm = (TextMessage) sub.receiveNoWait();
                
        }

> Inifinte loop in Java Client failover
> -------------------------------------
>
>                 Key: QPID-761
>                 URL: https://issues.apache.org/jira/browse/QPID-761
>             Project: Qpid
>          Issue Type: Bug
>          Components: Java Client
>    Affects Versions: M2, M2.1
>            Reporter: Rob Godfrey
>             Fix For: M2.1
>
>
> On reconnection on failover the java client attempt to set up the state as it was prior to failure.  If it is the creation of this state that caused the original failure, then the client may enter an infinite loop.
> My test was to create > 1000 sessions, each with a queue binding to a durable subscription 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.