Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Message-ID: <704914.771281105168917.JavaMail.jira@thor>
Date: Fri, 6 Aug 2010 10:32:48 -0400 (EDT)
From: "Gary Tully (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Resolved: (AMQ-2125) javax.jms.JMSException: Could not
 correlate acknowledgment with dispatched message thrown on failover
In-Reply-To: <155794312.1234959539368.JavaMail.jira@brutus>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit


     [ https://issues.apache.org/activemq/browse/AMQ-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gary Tully resolved AMQ-2125.
-----------------------------

      Assignee: Gary Tully
    Resolution: Fixed

log message at warn level in 5.4
r982990

> javax.jms.JMSException: Could not correlate acknowledgment with dispatched message thrown on failover
> -----------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-2125
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2125
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.2.0
>         Environment: MacOS 10.5 and Solaris 10
>            Reporter: Team Hiro
>            Assignee: Gary Tully
>             Fix For: 5.4.0
>
>
> When failing over to a new broker we see this exception. Although the exception is thrown no messages seem to be lost.
> This can be reproduced using the following unit test and this setup:
> 1. Create two activemq's using the same datasource.
> 2. Run the test
> 3. Kill the first active mq before the test completes (after you see the first Recieved Message... in the system out)
> 4. See the exception thrown in the second activemq log
> import org.apache.activemq.ActiveMQConnectionFactory;
> import javax.jms.*;
> import static javax.jms.Session.AUTO_ACKNOWLEDGE;
> import static javax.jms.Session.SESSION_TRANSACTED;
> import junit.framework.TestCase;
> import java.util.concurrent.atomic.AtomicInteger;
> public class BrokerTest extends TestCase {
>     public void testFoo() throws Exception {
>         ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("failover:(tcp://localhost:61616,tcp://localhost:61617)");
>         Connection connection = connectionFactory.createConnection();
>         connection.start();
>         Session producerSession = connection.createSession(false, AUTO_ACKNOWLEDGE);
>         MessageProducer producer = producerSession.createProducer(producerSession.createQueue("testQueue"));
>         for (int i = 0; i < 100; i++) {
>             System.out.println("Sending messages");
>             producer.send(producerSession.createTextMessage("Hello"));
>         }
>         final AtomicInteger atomicInteger = new AtomicInteger(0);
>         final Session consumerSession = connection.createSession(true, SESSION_TRANSACTED);
>         MessageConsumer messageConsumer = consumerSession.createConsumer(consumerSession.createQueue("testQueue"));
>         messageConsumer.setMessageListener(new MessageListener() {
>             public void onMessage(Message message) {
>                 try {
>                     System.out.println("Received Message" + message);
>                     Thread.sleep(1000);
>                     atomicInteger.addAndGet(1);
>                     System.out.println(atomicInteger.get());
>                     consumerSession.commit();
>                 } catch (Exception e) {
>                     throw new RuntimeException("Oh dear", e);
>                 }
>             }
>         });
>         Thread.sleep(2 * 60 * 1000);
>         assertEquals(100, atomicInteger.get());
>     }
> }

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