1 files changed, 10 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/SubscriptionImpl.cpp b/cpp/src/qpid/client/SubscriptionImpl.cpp
index 5ea87110c2..e09a4c142e 100644
--- a/cpp/src/qpid/client/SubscriptionImpl.cpp
+++ b/cpp/src/qpid/client/SubscriptionImpl.cpp
@@ -145,5 +145,15 @@ void SubscriptionImpl::received(Message& m) {
     }
 }
 
+Demux::QueuePtr SubscriptionImpl::divert()
+{
+    demuxRule = std::auto_ptr<ScopedDivert>(new ScopedDivert(name, manager.getSession().getExecution().getDemux()));
+    return demuxRule->getQueue();
+}
+
+void SubscriptionImpl::cancelDiversion() { 
+    demuxRule.reset();
+}
+
 }} // namespace qpid::client