diff options
| author | Gordon Sim <gsim@apache.org> | 2006-09-27 16:44:02 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2006-09-27 16:44:02 +0000 |
| commit | 9d718c2348708b0b27ce9fb9fcbf05c4b0a997cc (patch) | |
| tree | 4bea6ff87d58d3db712cbc727b9723680b1b981a /cpp/broker/inc/Message.h | |
| parent | 72aff4cc22932bd98b542ac9dd6393e23985e312 (diff) | |
| download | qpid-python-9d718c2348708b0b27ce9fb9fcbf05c4b0a997cc.tar.gz | |
Moved ack tests to basic class, added test for requeueing on recovery.
Implemented requeuing on recovery.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@450504 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/broker/inc/Message.h')
| -rw-r--r-- | cpp/broker/inc/Message.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/broker/inc/Message.h b/cpp/broker/inc/Message.h index 37a0c9b2c8..7a239adace 100644 --- a/cpp/broker/inc/Message.h +++ b/cpp/broker/inc/Message.h @@ -39,6 +39,7 @@ namespace qpid { string routingKey; const bool mandatory; const bool immediate; + bool redelivered; qpid::framing::AMQHeaderBody::shared_ptr header; content_list content; @@ -61,6 +62,7 @@ namespace qpid { void deliver(qpid::framing::OutputHandler* out, int channel, string& consumerTag, u_int64_t deliveryTag, u_int32_t framesize); + void redeliver(); friend bool route(Message::shared_ptr& msg, ExchangeRegistry* registry); |