activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sbuster <stevebuster...@hotmail.com>
Subject javax.jms.JMSException: Transaction 'TX:ID...' not started
Date Tue, 11 May 2010 19:36:27 GMT

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.


Mime
View raw message