activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Lukasz Zielinski (JIRA)" <j...@apache.org>
Subject [jira] Created: (AMQ-2225) PooledConnection obtaind from PooledConnectionFactory overwrites ExceptionListener
Date Fri, 24 Apr 2009 10:17:39 GMT
PooledConnection obtaind from PooledConnectionFactory overwrites ExceptionListener
----------------------------------------------------------------------------------

                 Key: AMQ-2225
                 URL: https://issues.apache.org/activemq/browse/AMQ-2225
             Project: ActiveMQ
          Issue Type: Bug
          Components: Broker
    Affects Versions: 5.2.0
            Reporter: Lukasz Zielinski
            Priority: Critical


When multiple connections are obtained from PooledConnectionFactory and ExceptionListeners
are set for them only one ExceptionListener will be notified about connection problems. Issue
is caused by overwriting listeners in shared connection.

Test case based on http://svn.apache.org/viewvc/activemq/trunk/activemq-pool/src/test/java/org/apache/activemq/pool/PooledTopicPublisherTest.java?view=markup

public void testSetGetExceptionListener2() throws Exception {
        PooledConnectionFactory pcf = new PooledConnectionFactory();
        pcf.setConnectionFactory(new ActiveMQConnectionFactory("vm://test"));

        TopicConnection conn1 = (TopicConnection) pcf.createConnection();
        ExceptionListener list1 = new ExceptionListener() {
            public void onException(JMSException exception) {
            }
        };
        conn1.setExceptionListener(list1);

        TopicConnection conn2 = (TopicConnection) pcf.createConnection();
        ExceptionListener list2 = new ExceptionListener() {
            public void onException(JMSException exception) {
            }
        };
        conn2.setExceptionListener(list2);

        assertEquals(list1, conn1.getExceptionListener());//this assertion will fail
        assertEquals(list2, conn2.getExceptionListener());//this assertion will pass

        assertEquals(list2, conn1.getExceptionListener());// THE PROBLEM
} 

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


Mime
View raw message