summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageHandlerImpl.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-08-21 15:51:41 +0000
committerGordon Sim <gsim@apache.org>2007-08-21 15:51:41 +0000
commitbb2883b9f5cfad0e028a9849ed91e36418a2d0ff (patch)
tree555686e2e819a875048610d88c2cee8e336b3687 /cpp/src/qpid/broker/MessageHandlerImpl.h
parent955d5ccb544ff4f56d35c40aa8934cbf4dfff14e (diff)
downloadqpid-python-bb2883b9f5cfad0e028a9849ed91e36418a2d0ff.tar.gz
Refresh of transitional xml to more closely reflect latest specification
Initial execution-result support (not yet handled on c++ client) Generation is now all done through the ruby code (it is a little slower at present I'm afraid, will try to speed it up over the next weeks) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@568174 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/MessageHandlerImpl.h')
-rw-r--r--cpp/src/qpid/broker/MessageHandlerImpl.h26
1 files changed, 16 insertions, 10 deletions
diff --git a/cpp/src/qpid/broker/MessageHandlerImpl.h b/cpp/src/qpid/broker/MessageHandlerImpl.h
index 20cae46da4..f4d9fa0c76 100644
--- a/cpp/src/qpid/broker/MessageHandlerImpl.h
+++ b/cpp/src/qpid/broker/MessageHandlerImpl.h
@@ -49,14 +49,6 @@ class MessageHandlerImpl :
void close(const std::string& reference );
- void consume(uint16_t ticket,
- const std::string& queue,
- const std::string& destination,
- bool noLocal,
- bool noAck,
- bool exclusive,
- const framing::FieldTable& filter );
-
void empty();
void get(uint16_t ticket,
@@ -76,8 +68,9 @@ class MessageHandlerImpl :
void recover(bool requeue );
- void reject(uint16_t code,
- const std::string& text );
+ void reject(const framing::SequenceNumberSet& transfers,
+ uint16_t code,
+ const std::string& text );
void resume(const std::string& reference,
const std::string& identifier );
@@ -92,6 +85,19 @@ class MessageHandlerImpl :
void stop(const std::string& destination);
+ void acquire(const framing::SequenceNumberSet& transfers, u_int8_t mode);
+
+ void release(const framing::SequenceNumberSet& transfers);
+
+ void subscribe(u_int16_t ticket,
+ const string& queue,
+ const string& destination,
+ bool noLocal,
+ u_int8_t confirmMode,
+ u_int8_t acquireMode,
+ bool exclusive,
+ const framing::FieldTable& filter);
+
private:
ReferenceRegistry references;
};