I had my eclipse env. pointing to version 5.3, all works fine now. I don't get the transaction error now message just disappears after 6 tries. I'll start another post on that topic.
Thanks Gary Tully wrote: > > odd, can you expand on what you did. > Did you download trunk? > What platform are you on? > Did u make any changes like run against an external broker? > > On 13 May 2010 13:15, sbuster <stevebuster...@hotmail.com> wrote: > >> >> Gary, >> Thanks for the response! I downloaded the JmsRollbackRedeliveryTest and >> get >> the same results, plus once a few test cases execute it hangs. BTW, none >> of >> hte test cases are successful. here is the output. >> >> May 13, 2010 7:12:39 AM org.apache.activemq.JmsRollbackRedeliveryTest >> doTestRedelivery >> INFO: Rollback message <hello id='1'/> id: >> ID:C001318805-3451-1273691609685-2:0:2:1:1 >> May 13, 2010 7:12:39 AM org.apache.activemq.broker.TransportConnection >> serviceException >> SEVERE: Async error occurred: javax.jms.JMSException: Transaction >> 'TX:ID:C001318805-1158-1273752758843-2:0:1' has not been started. >> javax.jms.JMSException: Transaction >> 'TX:ID:C001318805-1158-1273752758843-2:0:1' has not been started. >> at >> >> org.apache.activemq.broker.TransactionBroker.getTransaction(TransactionBroker.java:270) >> at >> >> org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:190) >> at >> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74) >> at >> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74) >> at >> >> org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:85) >> at >> >> org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:456) >> at >> org.apache.activemq.command.MessageAck.visit(MessageAck.java:205) >> at >> >> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305) >> at >> >> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) >> at >> >> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:104) >> at >> >> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68) >> at >> org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:205) >> at >> >> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122) >> at >> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43) >> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown >> Source) >> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown >> Source) >> at java.lang.Thread.run(Unknown Source) >> May 13, 2010 7:12:39 AM org.apache.activemq.JmsRollbackRedeliveryTest >> doTestRedelivery >> INFO: Received message <hello id='1'/> >> (0)ID:C001318805-3451-1273691609685-2:0:2:1:1 >> >> >> >> Gary Tully wrote: >> > >> > It will only get to the dlq when the redelivery policy retries are >> > exceeded >> > and this defaults to 6. You would need to configure that to 0 to get it >> > sent >> > to get a delivery to the DLQ. >> > >> > Can you try and produce a tests case for this behavior where the ack is >> > unexpected. >> > Pulling your code into the JMSConsumerTest does not reproduce. It works >> as >> > expected. >> > Maybe the JmsRollbackRedeliveryTest can give u a good starting point >> for >> a >> > test case or some examples that work: >> > >> > >> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ >> > >> > On 11 May 2010 20:36, sbuster <stevebuster...@hotmail.com> wrote: >> > >> >> >> >> I'm the same probelm as the other user in terms of using a simple >> >> transacted >> >> client that tries to call session.rollback and get the following >> >> exception >> >> in the log. Ultimately I want the message to end up in the DLQ but it >> >> never >> >> gets directed there. attached is a simple client, my activemq config. >> >> >> >> ActiveMQ 5.3.1 & 5.3.2 >> >> Using the default activemq.xml configuration file. >> >> >> >> Test Case >> >> public class MessageConsumerA { >> >> private String url = ActiveMQConnection.DEFAULT_BROKER_URL; >> >> private Session session; >> >> private Destination destination; >> >> private int ackMode = Session.AUTO_ACKNOWLEDGE; >> >> private boolean transacted=true; >> >> private String subject = "TOOL.DEFAULT"; >> >> javax.jms.MessageConsumer consumer = null; >> >> /** >> >> * @param args >> >> * @throws Exception >> >> */ >> >> public static void main(String[] args) throws Exception { >> >> MessageConsumerA mc = new MessageConsumerA(); >> >> mc.run(); >> >> >> >> } >> >> >> >> public void run() throws Exception{ >> >> ActiveMQConnectionFactory connectionFactory = new >> >> ActiveMQConnectionFactory(url); >> >> Connection connection = connectionFactory.createConnection(); >> >> connection.start(); >> >> session = connection.createSession(transacted, ackMode); >> >> destination = session.createQueue(subject); >> >> consumer = session.createConsumer(destination); >> >> Message message = consumer.receive(10000); >> >> session.rollback(); >> >> System.out.println("Closing connection"); >> >> consumer.close(); >> >> session.close(); >> >> connection.close(); >> >> } >> >> >> >> } >> >> >> >> >> >> Stack Trace: >> >> WARN | Async error occurred: javax.jms.JMSException: Transaction >> >> 'TX:ID:C001318 >> >> 805-4042-1273606494194-0:0:1' has not been started. >> >> javax.jms.JMSException: Transaction >> >> 'TX:ID:C001318805-4042-1273606494194-0:0:1' >> >> has not been started. >> >> at >> >> org.apache.activemq.broker.TransactionBroker.getTransaction(Transacti >> >> onBroker.java:270) >> >> at >> >> org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionB >> >> roker.java:190) >> >> at >> >> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java >> >> :74) >> >> at >> >> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java >> >> :74) >> >> at >> >> org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBro >> >> kerFilter.java:85) >> >> at >> >> org.apache.activemq.broker.TransportConnection.processMessageAck(Tran >> >> sportConnection.java:452) >> >> at >> >> org.apache.activemq.command.MessageAck.visit(MessageAck.java:205) >> >> at >> >> org.apache.activemq.broker.TransportConnection.service(TransportConne >> >> ction.java:300) >> >> at >> >> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC >> >> onnection.java:178) >> >> at >> >> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt >> >> er.java:68) >> >> at >> >> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireForm >> >> atNegotiator.java:113) >> >> at >> >> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityM >> >> onitor.java:216) >> >> at >> >> org.apache.activemq.transport.TransportSupport.doConsume(TransportSup >> >> port.java:84) >> >> at >> >> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.jav >> >> a:204) >> >> at >> >> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java: >> >> 186) >> >> at java.lang.Thread.run(Thread.java:619) >> >> -- >> >> View this message in context: >> >> >> http://old.nabble.com/javax.jms.JMSException%3A-Transaction-%27TX%3AID...%27-not-started-tp28528467p28528467.html >> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> >> >> >> >> > >> > >> > -- >> > http://blog.garytully.com >> > >> > Open Source Integration >> > http://fusesource.com >> > >> > >> >> -- >> View this message in context: >> http://old.nabble.com/javax.jms.JMSException%3A-Transaction-%27TX%3AID...%27-not-started-tp28528467p28546752.html >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> >> > > > -- > http://blog.garytully.com > > Open Source Integration > http://fusesource.com > > -- View this message in context: http://old.nabble.com/javax.jms.JMSException%3A-Transaction-%27TX%3AID...%27-not-started-tp28528467p28575886.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
