summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/messaging/MessageImpl.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2009-09-07 18:09:00 +0000
committerGordon Sim <gsim@apache.org>2009-09-07 18:09:00 +0000
commit8f0fd209fb0b31814fb7b1ff7a7271d1e3239cd3 (patch)
tree004b6eb7cfede3cf2b043373b002b4bccf3a3fd9 /cpp/src/qpid/messaging/MessageImpl.cpp
parentf44db8535081dfbf83197ccb0ae5bc24e82b714b (diff)
downloadqpid-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.cpp13
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