diff options
| author | Carl C. Trieloff <cctrieloff@apache.org> | 2008-09-30 14:57:32 +0000 |
|---|---|---|
| committer | Carl C. Trieloff <cctrieloff@apache.org> | 2008-09-30 14:57:32 +0000 |
| commit | ee83554e46565e532595b72ffcec70a257576d0c (patch) | |
| tree | 0fc133a8e3377049c52f163650c476659de2b44f /cpp/src/qpid/broker/Message.h | |
| parent | 94cbf28380264c1da0b24fee44dd51e1acbf9058 (diff) | |
| download | qpid-python-ee83554e46565e532595b72ffcec70a257576d0c.tar.gz | |
QPID-1306
This patch includes:
- Optimistic Consume
- Support for forcing Queue durable on cluster failure
- Some cleanup on mgnt functions in Queue to inlines
- Tests
Still coming
- header for client queue options
- LVQ support bits.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@700489 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Message.h')
| -rw-r--r-- | cpp/src/qpid/broker/Message.h | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Message.h b/cpp/src/qpid/broker/Message.h index a5ea0a7a37..8eb1b0b31c 100644 --- a/cpp/src/qpid/broker/Message.h +++ b/cpp/src/qpid/broker/Message.h @@ -133,6 +133,8 @@ public: bool isExcluded(const std::vector<std::string>& excludes) const; void addTraceId(const std::string& id); + + void forcePersistent(); private: mutable sys::Mutex lock; @@ -142,6 +144,7 @@ public: bool redelivered; bool loaded; bool staged; + bool forcePersistentPolicy; // used to force message as durable, via a broker policy ConnectionToken* publisher; mutable MessageAdapter* adapter; |
