summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Message.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-03-04 20:42:19 +0000
committerGordon Sim <gsim@apache.org>2008-03-04 20:42:19 +0000
commitd47950ff7a88e4684d1e07e334e705776ed569a7 (patch)
tree23f00efd6c9009f158c0b9643746dd16fd8adbf6 /cpp/src/qpid/broker/Message.cpp
parentcf9a1617599bb680deef2bab76fc6022f7dad50b (diff)
downloadqpid-python-d47950ff7a88e4684d1e07e334e705776ed569a7.tar.gz
Further updates to support final 0-10 spec
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@633627 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Message.cpp')
-rw-r--r--cpp/src/qpid/broker/Message.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Message.cpp b/cpp/src/qpid/broker/Message.cpp
index 1730c01099..a2c78daa7c 100644
--- a/cpp/src/qpid/broker/Message.cpp
+++ b/cpp/src/qpid/broker/Message.cpp
@@ -35,6 +35,7 @@ using namespace qpid::framing;
using std::string;
TransferAdapter Message::TRANSFER;
+PreviewAdapter Message::TRANSFER_99_0;
Message::Message(const SequenceNumber& id) : frames(id), persistenceId(0), redelivered(false), loaded(false), staged(false), publisher(0), adapter(0) {}
@@ -219,6 +220,8 @@ MessageAdapter& Message::getAdapter() const
{
if (!adapter) {
if(frames.isA<MessageTransferBody>()) {
+ adapter = &TRANSFER_99_0;
+ } else if(frames.isA<Message010TransferBody>()) {
adapter = &TRANSFER;
} else {
const AMQMethodBody* method = frames.getMethod();