diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionTest.java
index 37ccd7fc48..801b73fad7 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionTest.java
@@ -208,8 +208,8 @@ public class SessionTest extends ServiceTestBase
       clientSession.createConsumer(queueName);
       clientSession.createConsumer(queueName);
       ClientProducer cp = clientSession.createProducer("a1");
-      cp.send(clientSession.createMessage(false));
-      cp.send(clientSession.createMessage(false));
+      cp.send(clientSession.createMessage(true));
+      cp.send(clientSession.createMessage(true));
 
       flushQueue();