You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2011/12/21 23:35:29 UTC
svn commit: r1221922 - in /qpid/branches/qpid-3603/qpid/cpp/src/qpid:
broker/Consumer.h ha/ReplicatingSubscription.h
Author: aconway
Date: Wed Dec 21 22:35:28 2011
New Revision: 1221922
URL: http://svn.apache.org/viewvc?rev=1221922&view=rev
Log:
QPID-3603: Independent isDelayedCompletion for ReplicatingSubscription::DelegatingConsumer
The event messages sent to this consumer do not have delayed completion.
Modified:
qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/Consumer.h
qpid/branches/qpid-3603/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h
Modified: qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/Consumer.h
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/Consumer.h?rev=1221922&r1=1221921&r2=1221922&view=diff
==============================================================================
--- qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/Consumer.h (original)
+++ qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/Consumer.h Wed Dec 21 22:35:28 2011
@@ -57,6 +57,7 @@ class Consumer {
virtual bool filter(boost::intrusive_ptr<Message>) { return true; }
virtual bool accept(boost::intrusive_ptr<Message>) { return true; }
virtual OwnershipToken* getSession() = 0;
+ virtual bool isDelayedCompletion() const { return false; }
virtual ~Consumer(){}
friend class QueueListeners;
};
Modified: qpid/branches/qpid-3603/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-3603/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h?rev=1221922&r1=1221921&r2=1221922&view=diff
==============================================================================
--- qpid/branches/qpid-3603/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h (original)
+++ qpid/branches/qpid-3603/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h Wed Dec 21 22:35:28 2011
@@ -106,6 +106,7 @@ class ReplicatingSubscription : public b
void notify();
bool filter(boost::intrusive_ptr<broker::Message>);
bool accept(boost::intrusive_ptr<broker::Message>);
+ bool isDelayedCompletion() const { return false; }
broker::OwnershipToken* getSession();
private:
ReplicatingSubscription& delegate;
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org