diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientRequestor.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientRequestor.java index b81c3c4b44..3b2955b660 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientRequestor.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientRequestor.java @@ -94,6 +94,7 @@ public final class ClientRequestor implements AutoCloseable { * * @throws Exception if an exception occurs while closing the ClientRequestor */ + @Override public void close() throws Exception { replyConsumer.close(); requestProducer.close();