activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Christopher G. Stach II" <...@ldsys.net>
Subject Re: rollbacks not working (4.0RC3)
Date Wed, 17 May 2006 19:23:21 GMT
Hiram Chirino wrote:
> No,
> 
> I think you will need a more recent snapshot than RC3
> 

With 4.0 (release), I can't get it to deadlock anymore, but
rollback->redelivery still doesn't work.  Instead, I get a bunch of these:

org.apache.activemq.broker.AbstractConnection.serviceException Async
error occurred: javax.jms.JMSException: Could not correlate
acknowledgment with dispatched message: MessageAck {commandId = 193,
responseRequired = false, ackType = 1, consumerId =
ID:xxx-3212-1147892645742-2:5:-1:2, firstMessageId =
ID:xxx-3212-1147892645742-2:1:1:1:4, lastMessageId =
ID:xxx-3212-1147892645742-2:1:1:1:4, destination = queue://xxx,
transactionId = null, messageCount = 1}
javax.jms.JMSException: Could not correlate acknowledgment with
dispatched message: MessageAck {commandId = 193, responseRequired =
false, ackType = 1, consumerId = ID:xxx-3212-1147892645742-2:5:-1:2,
firstMessageId = ID:xxx-3212-1147892645742-2:1:1:1:4, lastMessageId =
ID:xxx-3212-1147892645742-2:1:1:1:4, destination = queue://xxxx,
transactionId = null, messageCount = 1}
        at
org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:175)
        at
org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:233)
        at
org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:362)
        at
org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:176)
        at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:65)
        at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:65)
        at
org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:78)
        at
org.apache.activemq.broker.AbstractConnection.processMessageAck(AbstractConnection.java:356)
        at org.apache.activemq.command.MessageAck.visit(MessageAck.java:178)
        at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
        at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
        at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
        at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
        at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
        at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
        at
org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1111)
        at
org.apache.activemq.ActiveMQSession.asyncSendPacket(ActiveMQSession.java:1655)
        at
org.apache.activemq.ActiveMQSession$2.afterRollback(ActiveMQSession.java:720)
        at
org.apache.activemq.TransactionContext.afterRollback(TransactionContext.java:134)
        at
org.apache.activemq.TransactionContext.rollback(TransactionContext.java:409)
        at
org.apache.activemq.ra.LocalAndXATransaction.rollback(LocalAndXATransaction.java:126)
        at
org.apache.geronimo.transaction.manager.WrapperNamedXAResource.rollback(WrapperNamedXAResource.java:78)
        at
com.caucho.transaction.TransactionImpl.rollbackInt(TransactionImpl.java:787)
        at
com.caucho.transaction.TransactionImpl.commit(TransactionImpl.java:560)
        at org.jencks.XAEndpoint.afterDelivery(XAEndpoint.java:103)
        at
org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.afterDelivery(MessageEndpointProxy.java:125)
        at
org.apache.activemq.ra.MessageEndpointProxy.afterDelivery(MessageEndpointProxy.java:64)
        at
org.apache.activemq.ra.ServerSessionImpl.afterDelivery(ServerSessionImpl.java:214)
        at org.apache.activemq.ActiveMQSession.run(ActiveMQSession.java:751)
        at
org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:163)
        at com.caucho.jca.WorkThread.run(WorkThread.java:99)
        at com.caucho.util.ThreadPool.runTasks(ThreadPool.java:490)
        at com.caucho.util.ThreadPool.run(ThreadPool.java:423)
        at java.lang.Thread.run(Thread.java:595)

This is the activemq.xml I'm using:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://activemq.org/config/1.0">

	<broker persistent="false" useJmx="false">
		<transportConnectors>
			<transportConnector uri="vm://localhost" />
		</transportConnectors>

		<persistenceAdapter>
			<memoryPersistenceAdapter />
		</persistenceAdapter>
	</broker>

</beans>

Here's the broker and RA configuration from Spring:

	<bean id="jms.broker" class="org.apache.activemq.xbean.BrokerFactoryBean">
		<property name="config">
			<value>classpath:activemq.xml</value>
		</property>

		<property name="start">
			<value>true</value>
		</property>
	</bean>

	<bean id="jms.resourceAdapter"
class="org.apache.activemq.ra.ActiveMQResourceAdapter"
depends-on="jms.broker">
		<property name="initialRedeliveryDelay">
			<value>2000</value>
		</property>

		<property name="maximumRedeliveries">
			<value>10</value>
		</property>

		<property name="redeliveryBackOffMultiplier">
			<value>2</value>
		</property>

		<property name="serverUrl">
			<value>vm://localhost</value>
		</property>
	</bean>

-- 
Christopher G. Stach II

Mime
View raw message