activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: javax.jms.JMSException: Transaction 'TX:ID...' not started
Date Wed, 12 May 2010 11:18:54 GMT
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 <stevebuster911@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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message