summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageHandlerImpl.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-10-04 12:01:28 +0000
committerGordon Sim <gsim@apache.org>2007-10-04 12:01:28 +0000
commit44c50b719e5685bd7a25cdeb9c5c9202ed8dc29a (patch)
tree0227574c78bff90a747c573393616b17ecddfccf /cpp/src/qpid/broker/MessageHandlerImpl.h
parent3263908aff26ae784d0399b03d869bfc1b035ebd (diff)
downloadqpid-python-44c50b719e5685bd7a25cdeb9c5c9202ed8dc29a.tar.gz
Fix (and refactor) processing of ranges in message handler.
Alter release() to push released messages onto head in reverse order (todo: make this atomic instead) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581869 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/MessageHandlerImpl.h')
-rw-r--r--cpp/src/qpid/broker/MessageHandlerImpl.h6
1 files changed, 6 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/MessageHandlerImpl.h b/cpp/src/qpid/broker/MessageHandlerImpl.h
index d90159d4f7..dd70f35dbb 100644
--- a/cpp/src/qpid/broker/MessageHandlerImpl.h
+++ b/cpp/src/qpid/broker/MessageHandlerImpl.h
@@ -25,6 +25,8 @@
#include "qpid/framing/AMQP_ClientProxy.h"
#include "HandlerImpl.h"
+#include <boost/function.hpp>
+
namespace qpid {
namespace broker {
@@ -36,6 +38,10 @@ class MessageHandlerImpl :
public framing::AMQP_ServerOperations::MessageHandler,
public HandlerImpl
{
+ typedef boost::function<void(DeliveryId, DeliveryId)> RangedOperation;
+ RangedOperation releaseOp;
+ RangedOperation rejectOp;
+
public:
MessageHandlerImpl(SemanticState&);