diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java index 457c379f96..a16c49dd2b 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java @@ -579,7 +579,8 @@ public class QueueControlTest extends ManagementTestBase { final String twentyBytes = new String(new char[20]).replace("\0", "#"); - ClientMessage clientMessage = createTextMessage(session, twentyBytes, true); + ClientMessage clientMessage = session.createMessage(Message.TEXT_TYPE, durable); + clientMessage.getBodyBuffer().writeNullableSimpleString(SimpleString.toSimpleString(twentyBytes)); clientMessage.putStringProperty("x", twentyBytes); QueueControl queueControl = createManagementControl(address, queue);