Author: aconway
Date: Thu Jan 19 23:07:07 2012
New Revision: 1233671
URL: http://svn.apache.org/viewvc?rev=1233671&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-2/qpid/cpp/src/qpid/broker/Consumer.h
qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h
Modified: qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/broker/Consumer.h
URL:
http://svn.apache.org/viewvc/qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/broker/Consumer.h?rev=1233671&r1=1233670&r2=1233671&view=diff
==============================================================================
--- qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/broker/Consumer.h (original)
+++ qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/broker/Consumer.h Thu Jan 19
23:07:07 2012
@@ -61,6 +61,7 @@ class Consumer {
virtual bool accept(boost::intrusive_ptr<Message>) { return true; }
virtual OwnershipToken* getSession() = 0;
virtual void cancel() = 0;
+ virtual bool isDelayedCompletion() const { return false; }
protected:
framing::SequenceNumber position;
Modified:
qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h
URL:
http://svn.apache.org/viewvc/qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h?rev=1233671&r1=1233670&r2=1233671&view=diff
==============================================================================
--- qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h
(original)
+++ qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h
Thu Jan 19 23:07:07 2012
@@ -104,10 +104,11 @@ class ReplicatingSubscription : public b
~DelegatingConsumer();
bool deliver(broker::QueuedMessage& msg);
void notify();
- bool filter(boost::intrusive_ptr<Message>);
- bool accept(boost::intrusive_ptr<Message>);
+ bool filter(boost::intrusive_ptr<broker::Message>);
+ bool accept(boost::intrusive_ptr<broker::Message>);
void cancel();
- OwnershipToken* getSession();
+ bool isDelayedCompletion() const { return false; }
+ broker::OwnershipToken* getSession();
private:
ReplicatingSubscription& delegate;
};
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
