diff --git a/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java b/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java
index 6298f418e9..8ef32e5b12 100755
--- a/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java
+++ b/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java
@@ -252,7 +252,7 @@ public abstract class Usage<T extends Usage> implements Service {
                     usageMutex.notifyAll();
                     for (Iterator<Runnable> iter = new ArrayList<Runnable>(callbacks).iterator(); iter.hasNext();) {
                         Runnable callback = iter.next();
-                        callback.run();
+                        getExecutor().execute(callback);
                     }
                     callbacks.clear();
                 }