Hi all I've been chasing this for quite a long time now:
The issue is related to http://www.nabble.com/Neither-rollback-nor-redeliver-the-message-tf2040790s2354.html#a5617084 this post . The setup is AMQ-4.1-SNAPSHOT+Jencks-2.0+Spring2; I don't use XA transaction (see xml bean definition at the bottom) and DUPS_OK_ACKNOWLEDGE, but the same behavior appears with AUTO_ACKNOWLEDGE. My test throws a RuntimeException within the onMessage(), what happens is that the connection and the consumer are removed (normal), but no matter the ActiveMQEndpointWorker.reconnect() only the consumer is ever recreated, as shown below... This results in no further message being consumed by the endpoint. I would be glad to have some feedback on this, the other post got no reply as well, and at this point I fear to be forced to catch(Throwable) right into the listener, quite ugly:S Thanks a lot, cheers Francesco /*** Trace ***/ main ] INFO org.apache.activemq.broker.BrokerService - ActiveMQ 4.1-SNAPSHOT JMS Message Broker (brokerConfigTest) is starting [main ] INFO org.apache.activemq.broker.BrokerService - For help or more information please see: http://incubator.apache.org/activemq/ [main ] INFO org.apache.activemq.kaha.impl.KahaStore - Kaha Store using data directory /tmp/activemq-data/kaha.db [main ] DEBUG org.apache.activemq.kaha.impl.data.DataManager - End of data file reached at (header was invalid): offset = 680, file = 1, size = 276 [JMX connector ] INFO org.apache.activemq.broker.jmx.ManagementContext - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi [main ] DEBUG org.apache.activemq.kaha.impl.data.DataManager - End of data file reached at (header was invalid): offset = 392784, file = 1, size = 370 [main ] INFO org.apache.activemq.transport.TransportServerThreadSupport - Listening for connections at: tcp://villomac.local:61616?jms.dispatchAsync=true&jms.dispatchAsync=true [main ] INFO org.apache.activemq.broker.TransportConnector - Connector tcp Started [main ] INFO org.apache.activemq.broker.BrokerService - ActiveMQ JMS Message Broker (brokerConfigTest, ID:villomac.local-52540-1181662829052-1:0) started [main ] DEBUG org.apache.xbean.spring.context.ResourceXmlApplicationContext - Publishing event in context [org.apache.xbean.spring.context.ResourceXmlApplicationContext;hashCode=1839964]: org.springframework.context.event.ContextRefreshedEvent[source=org.apache.xbean.spring.context.ResourceXmlApplicationContext: display name [org.apache.xbean.spring.context.ResourceXmlApplicationContext;hashCode=1839964]; startup date [Tue Jun 12 17:40:28 CEST 2007]; child of [org.springframework.context.support.ClassPathXmlApplicationContext: display name [org.springframework.context.support.ClassPathXmlApplicationContext;hashCode=7610781]; startup date [Tue Jun 12 17:40:28 CEST 2007]; root of context hierarchy]] [main ] INFO org.springframework.transaction.jta.JtaTransactionManager - Using JTA UserTransaction: [EMAIL PROTECTED] [main ] INFO org.springframework.transaction.jta.JtaTransactionManager - Using JTA TransactionManager: [EMAIL PROTECTED] [main ] DEBUG org.apache.geronimo.connector.outbound.AbstractSinglePoolConnectionInterceptor - Connection Manager org.jencks.factory.ConnectionManagerFactoryBean installed pool [EMAIL PROTECTED] [main ] INFO org.jencks.JCAContainer - Jencks JCA Container (http://jencks.org/) has started running version: null [main ] INFO org.jencks.JCAConnector - Activating endpoint for activationSpec: ActiveMQActivationSpec{acknowledgeMode='Dups-ok-acknowledge', destinationType='javax.jms.Queue', messageSelector='null', destination='queue1', clientId='null', subscriptionName='null', subscriptionDurability='NonDurable'} using endpointFactory: [EMAIL PROTECTED] [main ] DEBUG org.apache.activemq.ra.ActiveMQEndpointWorker - Starting [main ] DEBUG org.apache.activemq.ra.ActiveMQEndpointWorker - Started [main ] INFO org.jencks.JCAConnector - Activating endpoint for activationSpec: ActiveMQActivationSpec{acknowledgeMode='Dups-ok-acknowledge', destinationType='javax.jms.Queue', messageSelector='null', destination='queue2', clientId='null', subscriptionName='null', subscriptionDurability='NonDurable'} using endpointFactory: [EMAIL PROTECTED] [main ] DEBUG org.apache.activemq.ra.ActiveMQEndpointWorker - Starting [main ] DEBUG org.apache.activemq.ra.ActiveMQEndpointWorker - Started [pool-1-thread-1 ] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread starting [s.dispatchAsync=true] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [p:///127.0.0.1:52545] DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread starting [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp://localhost/127.0.0.1:61616 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} [p:///127.0.0.1:52545] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [p:///127.0.0.1:52545] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///127.0.0.1:52545 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp://localhost/127.0.0.1:61616 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} [p:///127.0.0.1:52545] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///127.0.0.1:52545 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} [p:///127.0.0.1:52545] DEBUG org.apache.activemq.broker.TransportConnection - Setting up new connection: [EMAIL PROTECTED] [p:///127.0.0.1:52545] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Connection ARRIVED =false SENDING [p:///127.0.0.1:52545] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Topic [p:///127.0.0.1:52545] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:villomac.local-52540-1181662829052-3:0:-1:1 [main ] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [p:///127.0.0.1:52546] DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread starting [s.dispatchAsync=true] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread starting [p:///127.0.0.1:52545] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:villomac.local-52540-1181662829052-3:0:-1:2 [p:///127.0.0.1:52545] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: queue://queue1 [p:///127.0.0.1:52546] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [p:///127.0.0.1:52546] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///127.0.0.1:52546 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} [p:///127.0.0.1:52546] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///127.0.0.1:52546 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp://localhost/127.0.0.1:61616 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp://localhost/127.0.0.1:61616 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} [p:///127.0.0.1:52545] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Queue [p:///127.0.0.1:52545] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Consumer.Queue.queue1 [main ] DEBUG org.apache.geronimo.connector.outbound.SinglePoolConnectionInterceptor - Supplying new connection MCI: [EMAIL PROTECTED] MC: [EMAIL PROTECTED] from pool: [EMAIL PROTECTED] [p:///127.0.0.1:52547] DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread starting [pool-1-thread-1 ] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [s.dispatchAsync=true] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [p:///127.0.0.1:52547] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [p:///127.0.0.1:52547] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///127.0.0.1:52547 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} [p:///127.0.0.1:52547] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///127.0.0.1:52547 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} [p:///127.0.0.1:52546] DEBUG org.apache.activemq.broker.TransportConnection - Setting up new connection: [EMAIL PROTECTED] [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread starting [p:///127.0.0.1:52546] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:villomac.local-52540-1181662829052-3:1:-1:1 [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp://localhost/127.0.0.1:61616 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp://localhost/127.0.0.1:61616 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.TransportConnection - Setting up new connection: [EMAIL PROTECTED] [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:villomac.local-52540-1181662829052-3:2:-1:1 [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:villomac.local-52540-1181662829052-3:2:-1:2 [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: queue://queue2 [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Consumer.Queue.queue2 [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - ServerSession requested. [p:///127.0.0.1:52546] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Producer.Queue.queue2 [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Created a new session: ServerSessionImpl:0 [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:0 - Starting run. [main ] DEBUG org.apache.activemq.ActiveMQSession - Sending message: ActiveMQObjectMessage {commandId = 0, responseRequired = false, messageId = ID:villomac.local-52540-1181662829052-3:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:villomac.local-52540-1181662829052-3:1:1:1, destination = queue://queue2, transactionId = null, expiration = 0, timestamp = 1181662830501, arrival = 0, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = [EMAIL PROTECTED], marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = true, readOnlyBody = true, droppable = false} [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:0 - Work accepted: [EMAIL PROTECTED] [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - ServerSession requested. [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Created a new session: ServerSessionImpl:1 [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Starting run. [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Work accepted: [EMAIL PROTECTED] [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - ServerSession requested. [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Created a new session: ServerSessionImpl:2 [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Starting run. [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Work accepted: [EMAIL PROTECTED] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:0 - Work started: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:0] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:0 - Running [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:0 - run loop start [pool-1-thread-1 ] ERROR org.apache.activemq.ActiveMQSession - error dispatching message: java.lang.NullPointerException at net.ripe.hstcnt.bare.ThrowsExceptionMessage.getZone(ThrowsExceptionMessage.java:16) at net.ripe.hstcnt.bare.RecordingMessageListener.onMessage(RecordingMessageListener.java:42) at net.ripe.hstcnt.bare.BareMessageListener.onMessage(BareMessageListener.java:24) at org.jencks.LocalTransactionEndpoint.onMessage(LocalTransactionEndpoint.java:68) at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.onMessage(MessageEndpointProxy.java:121) at org.apache.activemq.ra.MessageEndpointProxy.onMessage(MessageEndpointProxy.java:61) at org.apache.activemq.ActiveMQSession.run(ActiveMQSession.java:696) at org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:165) at org.apache.geronimo.connector.work.WorkerContext.run(WorkerContext.java:290) at org.apache.geronimo.connector.work.pool.NamedRunnable.run(NamedRunnable.java:32) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) at java.lang.Thread.run(Thread.java:613) [main ] DEBUG org.apache.geronimo.connector.outbound.GeronimoConnectionEventListener - connectionClosed called with [EMAIL PROTECTED] for MCI: [EMAIL PROTECTED] and MC: [EMAIL PROTECTED] [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ActiveMQEndpointWorker - Reconnect cause: javax.jms.JMSException: java.lang.NullPointerException at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:46) at org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1525) at org.apache.activemq.ActiveMQSession.run(ActiveMQSession.java:700) at org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:165) at org.apache.geronimo.connector.work.WorkerContext.run(WorkerContext.java:290) at org.apache.geronimo.connector.work.pool.NamedRunnable.run(NamedRunnable.java:32) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) at java.lang.Thread.run(Thread.java:613) Caused by: java.lang.NullPointerException at net.ripe.hstcnt.bare.ThrowsExceptionMessage.getZone(ThrowsExceptionMessage.java:16) at net.ripe.hstcnt.bare.RecordingMessageListener.onMessage(RecordingMessageListener.java:42) at net.ripe.hstcnt.bare.BareMessageListener.onMessage(BareMessageListener.java:24) at org.jencks.LocalTransactionEndpoint.onMessage(LocalTransactionEndpoint.java:68) at org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.onMessage(MessageEndpointProxy.java:121) at org.apache.activemq.ra.MessageEndpointProxy.onMessage(MessageEndpointProxy.java:61) at org.apache.activemq.ActiveMQSession.run(ActiveMQSession.java:696) ... 6 more [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:0 - run loop end [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Session returned to pool: ServerSessionImpl:0 [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:0 - Run finished [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:0 - Work completed: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:0] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Work started: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:1] [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.region.AbstractRegion - Removing consumer: ID:villomac.local-52540-1181662829052-3:2:-1:2 [main ] DEBUG org.apache.geronimo.connector.outbound.TransactionCachingInterceptor - tx ended, returning [EMAIL PROTECTED] for managed connection [EMAIL PROTECTED] to tx caching interceptor [EMAIL PROTECTED] [main ] DEBUG org.apache.geronimo.connector.outbound.AbstractSinglePoolConnectionInterceptor - returning connection [EMAIL PROTECTED] for MCI [EMAIL PROTECTED] and MC [EMAIL PROTECTED] to pool [EMAIL PROTECTED] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Running [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.region.AbstractRegion - Removing consumer: ID:villomac.local-52540-1181662829052-3:2:-1:1 [p:///127.0.0.1:52546] DEBUG org.apache.activemq.broker.region.AbstractRegion - Removing consumer: ID:villomac.local-52540-1181662829052-3:1:-1:1 [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - run loop start [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - run loop end [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Session returned to pool: ServerSessionImpl:1 [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Run finished [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Work completed: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:1] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Work started: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:2] [main ] DEBUG org.apache.geronimo.connector.outbound.TransactionCachingInterceptor - completed return of connection through tx cache [EMAIL PROTECTED] for MCI: [EMAIL PROTECTED] and MC [EMAIL PROTECTED] to tx caching interceptor [EMAIL PROTECTED] [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.TransportConnection - Stopping connection: /127.0.0.1:52547 [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Running [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - run loop start [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - run loop end [p:///127.0.0.1:52547] DEBUG org.apache.activemq.broker.TransportConnection - Stopped connection: /127.0.0.1:52547 [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Session returned to pool: ServerSessionImpl:2 [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Run finished [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Work completed: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:2] [pool-1-thread-1 ] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [s.dispatchAsync=true] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [p:///127.0.0.1:52548] DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread starting [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread starting [p:///127.0.0.1:52548] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [p:///127.0.0.1:52548] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///127.0.0.1:52548 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} [p:///127.0.0.1:52548] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///127.0.0.1:52548 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp://localhost/127.0.0.1:61616 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} [host/127.0.0.1:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp://localhost/127.0.0.1:61616 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} [p:///127.0.0.1:52548] DEBUG org.apache.activemq.broker.TransportConnection - Setting up new connection: [EMAIL PROTECTED] [p:///127.0.0.1:52548] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:villomac.local-52540-1181662829052-3:3:-1:1 [p:///127.0.0.1:52548] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:villomac.local-52540-1181662829052-3:3:-1:2 [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - ServerSession requested. [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Using idle session: ServerSessionImpl:2 [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Starting run. [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Work accepted: [EMAIL PROTECTED] [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - ServerSession requested. [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Using idle session: ServerSessionImpl:1 [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Starting run. [host/127.0.0.1:61616] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Work accepted: [EMAIL PROTECTED] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Work started: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:2] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Running [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - run loop start [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - run loop end [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Session returned to pool: ServerSessionImpl:2 [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Run finished [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:2 - Work completed: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:2] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Work started: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:1] [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Running [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - run loop start [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - run loop end [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionPoolImpl - Session returned to pool: ServerSessionImpl:1 [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Run finished [pool-1-thread-1 ] DEBUG org.apache.activemq.ra.ServerSessionImpl:1 - Work completed: javax.resource.spi.work.WorkEvent[source=Work :ServerSessionImpl:1] /*** Spring bean definitions ***/ <bean id="transactionManager" class="org.jencks.factory.TransactionManagerFactoryBean"/> <!-- Jencks Connection Manager --> <bean id="connectionManager" class="org.jencks.factory.ConnectionManagerFactoryBean"> <property name="transactionManager" ref="transactionManager"/> <property name="transaction" value="local"/> <property name="pooling" value="true"/> <property name="allConnectionsEqual" value="true"/> <property name="poolMaxSize" value="100"/> <property name="poolMinSize" value="1"/> <property name="connectionMaxWaitMilliseconds" value="60"/> <property name="connectionMaxIdleMinutes" value="60"/> </bean> <bean id="jmsResourceAdapter" class="org.apache.activemq.ra.ActiveMQResourceAdapter" depends-on="broker"> <!--<property name="serverUrl" value="vm://HCBroker"/>--> <property name="serverUrl" value="tcp://localhost:61616?jms.useAsyncSend=true&jms.dispatchAsync=true"/> <!--<property name="serverUrl" value="vm://HCBroker?jms.useAsyncSend=true&jms.dispatchAsync=true"/>--> <!--<property name="queuePrefetch" value="1000"/>--> </bean> <bean id="jmsManagedConnectionFactory" class="org.apache.activemq.ra.ActiveMQManagedConnectionFactory" depends-on="jmsResourceAdapter"> <property name="resourceAdapter" ref="jmsResourceAdapter"/> </bean> <bean id="jmsConnectionFactory" class="org.jencks.factory.ConnectionFactoryFactoryBean"> <property name="managedConnectionFactory" ref="jmsManagedConnectionFactory"/> <property name="connectionManager" ref="connectionManager"/> </bean> <bean id="jencksJCAContainer" class="org.jencks.JCAContainer"> <property name="lazyLoad" value="true"/> <property name="transactionManager" ref="transactionManager"/> <property name="threadPoolSize"> <value>1</value> </property> <property name="resourceAdapter" ref="jmsResourceAdapter"/> </bean> <bean id="inboundConnector2" class="org.jencks.JCAConnector"> <property name="jcaContainer" ref="jencksJCAContainer"/> <property name="activationSpec"> <bean class="org.apache.activemq.ra.ActiveMQActivationSpec"> <property name="destination" value="queue2"/> <property name="destinationType" value="javax.jms.Queue"/> <property name="acknowledgeMode" value="Dups-ok-acknowledge"/> <property name="maxSessions" value="80"/> <property name="maxMessagesPerSessions" value="10000"/> </bean> </property> <property name="ref" value="listener2"/> </bean> /*** Test code ***/ public void testRuntimeException() throws Exception { applicationContext = new ClassPathXmlApplicationContext(new String[]{ basePath + "jms-bare/jms.xml", basePath + "jms-bare/container.xml", basePath + "jms-bare/2queues-dupsok.xml" }); JmsTemplate sender = new JmsTemplate((ConnectionFactory) applicationContext.getBean("jmsConnectionFactory")); sender.setDefaultDestination((Destination) applicationContext.getBean("queue2")); sender.setSessionAcknowledgeMode(Session.DUPS_OK_ACKNOWLEDGE); RecordingMessageListener l2 = (RecordingMessageListener) applicationContext.getBean("listener2"); l2.setExpected(1); MessageObserver observer = new MessageObserver(); l2.setObserver(observer); observer.start(); System.out.println("SENDING"); sender.convertAndSend(new ThrowsExceptionMessage("testexception")); observer.join(); } -- View this message in context: http://www.nabble.com/No-redelivery-reconnect-after-unchecked-exception-tf3908350s2354.html#a11081437 Sent from the ActiveMQ - User mailing list archive at Nabble.com.
