1 files changed, 6 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java
index cbc8664574..0e19b17a50 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java
@@ -275,7 +275,7 @@ public class Subscription_0_10 implements Subscription, FlowCreditManager.FlowCr
             }
             _creditManager.removeListener(this);
             getConfigStore().removeConfiguredObject(this);
-            CurrentActor.get().message(SubscriptionMessages.CLOSE());
+            CurrentActor.get().message(getLogSubject(), SubscriptionMessages.CLOSE());
         }
         finally
         {
@@ -948,4 +948,9 @@ public class Subscription_0_10 implements Subscription, FlowCreditManager.FlowCr
         return filterLogString.toString();
     }
 
+    public LogSubject getLogSubject()
+    {
+        return (LogSubject) this;
+    }
+
 }