diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/divert/DivertTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/divert/DivertTest.java index 3d7100464e..eaf1a2c7a6 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/divert/DivertTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/divert/DivertTest.java @@ -356,7 +356,7 @@ public class DivertTest extends ActiveMQTestBase { System.out.println("Received message " + message); assertNotNull(message); - if (message.getStringProperty(Message.HDR_ORIGINAL_QUEUE).equals("queue1")) { + if (message.getStringProperty(Message.HDR_ORIGINAL_QUEUE).equals("divert1")) { countOriginal1++; } else if (message.getStringProperty(Message.HDR_ORIGINAL_QUEUE).equals("queue2")) { countOriginal2++;