diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java index 53a7533869..57ff6a4fa2 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java @@ -205,7 +205,7 @@ public class AMQConnectionTest extends QpidBrokerTestCase Session consSessA = _connection.createSession(true, Session.AUTO_ACKNOWLEDGE); MessageConsumer consumerA = consSessA.createConsumer(_queue); - Session producerSession = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + Session producerSession = _connection.createSession(true, Session.SESSION_TRANSACTED); MessageProducer producer = producerSession.createProducer(_queue); // Send 3 messages @@ -213,6 +213,7 @@ public class AMQConnectionTest extends QpidBrokerTestCase { producer.send(producerSession.createTextMessage("test")); } + producerSession.commit(); MessageConsumer consumerB = null; // 0-8, 0-9, 0-9-1 prefetch is per session, not consumer. |