diff options
author | Gordon Sim <gsim@apache.org> | 2009-09-07 18:09:00 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2009-09-07 18:09:00 +0000 |
commit | 8f0fd209fb0b31814fb7b1ff7a7271d1e3239cd3 (patch) | |
tree | 004b6eb7cfede3cf2b043373b002b4bccf3a3fd9 /cpp/src/qpid/messaging/MessageImpl.cpp | |
parent | f44db8535081dfbf83197ccb0ae5bc24e82b714b (diff) | |
download | qpid-python-8f0fd209fb0b31814fb7b1ff7a7271d1e3239cd3.tar.gz |
QPID-664: Added automatic message replay on reconnection.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@812243 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/messaging/MessageImpl.cpp')
-rw-r--r-- | cpp/src/qpid/messaging/MessageImpl.cpp | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/cpp/src/qpid/messaging/MessageImpl.cpp b/cpp/src/qpid/messaging/MessageImpl.cpp index 402a93e753..5df9218e03 100644 --- a/cpp/src/qpid/messaging/MessageImpl.cpp +++ b/cpp/src/qpid/messaging/MessageImpl.cpp @@ -126,6 +126,15 @@ void MessageImpl::encode(Codec& codec) } } +void MessageImpl::getEncodedContent(Codec& codec, std::string& out) const +{ + if (content.getType() != VAR_VOID) { + codec.encode(content, out); + } else { + out = bytes; + } +} + void MessageImpl::decode(Codec& codec) { codec.decode(bytes, content); @@ -188,5 +197,9 @@ MessageImpl& MessageImplAccess::get(Message& msg) { return *msg.impl; } +const MessageImpl& MessageImplAccess::get(const Message& msg) +{ + return *msg.impl; +} }} // namespace qpid::messaging |