diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java
index 0ba9c91076..dcf5d54ec2 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java
@@ -309,7 +309,7 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
 
          @Override
          public int removeAllMessages() throws Exception {
-            return (Integer) proxy.invokeOperation( "removeAllMessages");
+            return (Integer) proxy.invokeOperation(Integer.class, "removeAllMessages");
          }
 
          @Override