Return-Path: Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org Received: (qmail 96855 invoked from network); 14 Dec 2006 00:53:15 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 14 Dec 2006 00:53:15 -0000 Received: (qmail 25359 invoked by uid 500); 14 Dec 2006 00:53:22 -0000 Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org Received: (qmail 25333 invoked by uid 500); 14 Dec 2006 00:53:22 -0000 Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-users@geronimo.apache.org Delivered-To: mailing list activemq-users@geronimo.apache.org Received: (qmail 25324 invoked by uid 99); 14 Dec 2006 00:53:22 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Dec 2006 16:53:22 -0800 X-ASF-Spam-Status: No, hits=2.0 required=10.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (herse.apache.org: domain of crasheddrive@gmail.com designates 64.233.182.184 as permitted sender) Received: from [64.233.182.184] (HELO nf-out-0910.google.com) (64.233.182.184) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Dec 2006 16:53:11 -0800 Received: by nf-out-0910.google.com with SMTP id x37so643084nfc for ; Wed, 13 Dec 2006 16:52:50 -0800 (PST) DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws; s=beta; d=gmail.com; h=received:message-id:date:from:to:subject:mime-version:content-type; b=rkhzufF/l+3t+f/M52GWxLQ9Rv07UeKg6mXstz+7soi5SSgqGfdbbnC7gKbKpIgu9H+rGR/I3xocw22GQyMN2YFg71xujFxmHmdxv1B6ltPW1qADcIbcgyZQ6pbylztXjssvOThiyZivOvtGsRTCQjvVJkY9pWksoDubbNtdB/A= Received: by 10.82.153.5 with SMTP id a5mr151724bue.1166057569252; Wed, 13 Dec 2006 16:52:49 -0800 (PST) Received: by 10.82.113.8 with HTTP; Wed, 13 Dec 2006 16:52:49 -0800 (PST) Message-ID: <1a7e23b50612131652q7037c8dt48ef14782b4f0d3c@mail.gmail.com> Date: Wed, 13 Dec 2006 18:52:49 -0600 From: "Tim Chen" To: activemq-users@geronimo.apache.org Subject: Throwing exception during Message read fails after retry. MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="----=_Part_98190_23734772.1166057569204" X-Virus-Checked: Checked by ClamAV on apache.org ------=_Part_98190_23734772.1166057569204 Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit Content-Disposition: inline The follow exception is thrown which kills the MessageListener and leave the bad message in the queue. [junit] 18:22:28,437 DEBUG [org.apache.activemq.ra.ServerSessionImpl:2] Endpoint failed to process message. [junit] java.lang.RuntimeException: Endpoint after delivery notification failure [junit] at org.apache.activemq.ra.ServerSessionImpl.afterDelivery( ServerSessionImpl.java:217) [junit] at org.apache.activemq.ActiveMQSession.run( ActiveMQSession.java:751) [junit] at org.apache.activemq.ra.ServerSessionImpl.run( ServerSessionImpl.java:164) [junit] at org.apache.geronimo.connector.work.WorkerContext.run( WorkerContext.java:291) [junit] at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run( PooledExecutor.java:748) [junit] at java.lang.Thread.run(Thread.java:595) [junit] Caused by: javax.resource.ResourceException: commit failed. [junit] at org.apache.activemq.ra.LocalAndXATransaction.commit( LocalAndXATransaction.java:59) [junit] at org.jencks.LocalTransactionEndpoint.afterDelivery( LocalTransactionEndpoint.java:52) [junit] at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.afterDelivery (MessageEndpointProxy.java:125) [junit] at org.apache.activemq.ra.MessageEndpointProxy.afterDelivery (MessageEndpointProxy.java:64) [junit] at org.apache.activemq.ra.ServerSessionImpl.afterDelivery( ServerSessionImpl.java:215) [junit] ... 5 more [junit] Caused by: org.apache.activemq.ConnectionClosedException: The connection is already closed [junit] at org.apache.activemq.ActiveMQConnection.syncSendPacket( ActiveMQConnection.java:1108) [junit] at org.apache.activemq.TransactionContext.commit( TransactionContext.java:259) [junit] at org.apache.activemq.ra.LocalAndXATransaction.commit( LocalAndXATransaction.java:57) [junit] ... 9 more [junit] 18:22:28,440 INFO [org.apache.activemq.ra.ServerSessionImpl:2] Endpoint failed to process message. Reason: java.lang.RuntimeException: Endpoint after delivery notification failure [junit] 18:22:28,440 DEBUG [org.apache.activemq.ra.ServerSessionImpl:2] run loop end [junit] 18:22:28,440 DEBUG [org.apache.activemq.ra.ServerSessionImpl:2] Endpoint did not release properly: org.apache.activemq.ra.InvalidMessageEndpointException [junit] org.apache.activemq.ra.InvalidMessageEndpointException [junit] at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointDead.release( MessageEndpointProxy.java:156) [junit] at org.apache.activemq.ra.MessageEndpointProxy.release( MessageEndpointProxy.java:68) [junit] at org.apache.activemq.ra.ServerSessionImpl.close( ServerSessionImpl.java:252) [junit] at org.apache.activemq.ra.ServerSessionPoolImpl.removeFromPool( ServerSessionPoolImpl.java:180) [junit] at org.apache.activemq.ra.ServerSessionImpl.run( ServerSessionImpl.java:178) [junit] at org.apache.geronimo.connector.work.WorkerContext.run( WorkerContext.java:291) [junit] at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run( PooledExecutor.java:748) [junit] at java.lang.Thread.run(Thread.java:595) [junit] 18:22:28,441 DEBUG [org.apache.activemq.ra.ServerSessionImpl:2] Run finished [junit] 18:22:28,441 DEBUG [org.apache.activemq.ra.ServerSessionImpl:2] Work completed: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:2] [junit] 18:22:28,396 WARN [org.jencks.LocalTransactionEndpoint] Failed to rollback local transaction: javax.resource.ResourceException: rollback failed. [junit] javax.resource.ResourceException: rollback failed. [junit] at org.apache.activemq.ra.LocalAndXATransaction.rollback( LocalAndXATransaction.java:73) [junit] at org.jencks.LocalTransactionEndpoint.release( LocalTransactionEndpoint.java:58) [junit] at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointDead.enter( MessageEndpointProxy.java:140) [junit] at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointState.transition( MessageEndpointProxy.java:98) [junit] at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.beforeDelivery (MessageEndpointProxy.java:114) [junit] at org.apache.activemq.ra.MessageEndpointProxy.beforeDelivery( MessageEndpointProxy.java:56) [junit] at org.apache.activemq.ra.ServerSessionImpl.beforeDelivery( ServerSessionImpl.java:200) [junit] at org.apache.activemq.ActiveMQSession.run( ActiveMQSession.java:686) [junit] at org.apache.activemq.ra.ServerSessionImpl.run( ServerSessionImpl.java:164) [junit] at org.apache.geronimo.connector.work.WorkerContext.run( WorkerContext.java:291) [junit] at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run( PooledExecutor.java:743) [junit] at java.lang.Thread.run(Thread.java:595) [junit] Caused by: org.apache.activemq.ConnectionClosedException: The connection is already closed [junit] at org.apache.activemq.ActiveMQConnection.asyncSendPacket( ActiveMQConnection.java:1088) [junit] at org.apache.activemq.TransactionContext.rollback( TransactionContext.java:225) [junit] at org.apache.activemq.ra.LocalAndXATransaction.rollback( LocalAndXATransaction.java:71) [junit] ... 11 more [junit] 18:22:28,441 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Endpoint failed to process message. [junit] java.lang.RuntimeException: Endpoint before delivery notification failure [junit] at org.apache.activemq.ra.ServerSessionImpl.beforeDelivery( ServerSessionImpl.java:202) [junit] at org.apache.activemq.ActiveMQSession.run( ActiveMQSession.java:686) [junit] at org.apache.activemq.ra.ServerSessionImpl.run( ServerSessionImpl.java:164) [junit] at org.apache.geronimo.connector.work.WorkerContext.run( WorkerContext.java:291) [junit] at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run( PooledExecutor.java:743) [junit] at java.lang.Thread.run(Thread.java:595) [junit] Caused by: javax.resource.ResourceException: begin failed. [junit] at org.apache.activemq.ra.LocalAndXATransaction.begin( LocalAndXATransaction.java:51) [junit] at org.jencks.LocalTransactionEndpoint.beforeDelivery( LocalTransactionEndpoint.java:48) [junit] at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.beforeDelivery (MessageEndpointProxy.java:109) [junit] at org.apache.activemq.ra.MessageEndpointProxy.beforeDelivery( MessageEndpointProxy.java:56) [junit] at org.apache.activemq.ra.ServerSessionImpl.beforeDelivery( ServerSessionImpl.java:200) [junit] ... 5 more [junit] Caused by: javax.jms.JMSException: Transport disposed. [junit] at org.apache.activemq.util.JMSExceptionSupport.create( JMSExceptionSupport.java:57) [junit] at org.apache.activemq.ActiveMQConnection.asyncSendPacket( ActiveMQConnection.java:1094) [junit] at org.apache.activemq.TransactionContext.begin( TransactionContext.java:199) [junit] at org.apache.activemq.ra.LocalAndXATransaction.begin( LocalAndXATransaction.java:48) [junit] ... 9 more [junit] Caused by: java.io.IOException: Transport disposed. [junit] at org.apache.activemq.transport.vm.VMTransport.oneway( VMTransport.java:69) [junit] at org.apache.activemq.transport.MutexTransport.oneway( MutexTransport.java:44) [junit] at org.apache.activemq.transport.ResponseCorrelator.oneway( ResponseCorrelator.java:60) [junit] at org.apache.activemq.ActiveMQConnection.asyncSendPacket( ActiveMQConnection.java:1092) [junit] ... 11 more [junit] 18:22:28,525 INFO [org.apache.activemq.ra.ServerSessionImpl:1] Endpoint failed to process message. Reason: java.lang.RuntimeException: Endpoint before delivery notification failure [junit] 18:22:28,525 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] run loop end [junit] 18:22:28,525 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Endpoint did not release properly: org.apache.activemq.ra.InvalidMessageEndpointException [junit] org.apache.activemq.ra.InvalidMessageEndpointException [junit] at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointDead.release( MessageEndpointProxy.java:156) [junit] at org.apache.activemq.ra.MessageEndpointProxy.release( MessageEndpointProxy.java:68) [junit] at org.apache.activemq.ra.ServerSessionImpl.close( ServerSessionImpl.java:252) [junit] at org.apache.activemq.ra.ServerSessionPoolImpl.removeFromPool( ServerSessionPoolImpl.java:180) [junit] at org.apache.activemq.ra.ServerSessionImpl.run( ServerSessionImpl.java:178) [junit] at org.apache.geronimo.connector.work.WorkerContext.run( WorkerContext.java:291) [junit] at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run( PooledExecutor.java:743) [junit] at java.lang.Thread.run(Thread.java:595) Setup is ActiveMQ 4.1-SNAPSHOT/Jencks 1.3/Spring 2.0.1 Strangely enough if you put the transactionManager back in it doesn't have the error but it doesn't seem to send to the DLQ. It ignores the maximumRedeliveries option as well. I could set it to 1 and see multiple consumer retries. Is this a bug with 4.1-SNAPSHOT and/or Jencks or is this a configuration issue? ------=_Part_98190_23734772.1166057569204--