Session.commit() hangs when amqp+nio is used

Steps to reproduce: 0) Uncomment line admin=admin,admin in etc/users.properties 1)before starting fuse in etc/activemq.xml substitute line: <transportConnector name="openwire" uri="tcp://0.0.0.0:0?maximumConnections=1000"/> with <transportConnector name="amqp" uri="amqp+nio://localhost:5672"/> 2) Using the following dependencies: <dependency> <groupId>org.apache.qpid</groupId> <artifactId>qpid-amqp-1-0-client-jms</artifactId> <version>0.26-SNAPSHOT</version> </dependency> <dependency> <groupId>org.apache.geronimo.specs</groupId> <artifactId>geronimo-jms_1.1_spec</artifactId> <version>1.0</version> </dependency> I ran the following test: @Test public void sessionTransactedTest() throws JMSException, InterruptedException { System.out.println(" sessionTransactedTest");   c = cf.createConnection(); c.start(); // transaction Session transactedSession = c.createSession(true, 0); Destination queue = transactedSession.createQueue("TransQueue"); MessageProducer pr = transactedSession.createProducer(queue); for (int i = 0; i < 10; i++) { Message m = transactedSession.createTextMessage("TestMessage" + i); pr.send(m); } MessageConsumer cons = transactedSession.createConsumer(queue); TextMessage m = (TextMessage) cons.receive(5000); System.out.println(" consumer message recieved"); Assert.assertNull(m); transactedSession.commit(); System.out.println(" transaction commited"); transactedSession.close(); System.out.println(" transaction closed"); } The test hangs on the line transactedSession.commit() in 90% of execution.