summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageAdapter.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/MessageAdapter.cpp')
-rw-r--r--cpp/src/qpid/broker/MessageAdapter.cpp8
1 files changed, 6 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/MessageAdapter.cpp b/cpp/src/qpid/broker/MessageAdapter.cpp
index 2c29aa5444..a70de72646 100644
--- a/cpp/src/qpid/broker/MessageAdapter.cpp
+++ b/cpp/src/qpid/broker/MessageAdapter.cpp
@@ -36,12 +36,12 @@ namespace broker{
std::string TransferAdapter::getExchange(const framing::FrameSet& f)
{
- return f.as<framing::MessageTransferBody>()->getDestination();
+ return f.as<framing::Message010TransferBody>()->getDestination();
}
bool TransferAdapter::isImmediate(const framing::FrameSet&)
{
- //TODO: we seem to have lost the immediate flag
+ //TODO: delete this, immediate is no longer part of the spec
return false;
}
@@ -57,4 +57,8 @@ namespace broker{
return p && p->getDeliveryMode() == 2;
}
+ std::string PreviewAdapter::getExchange(const framing::FrameSet& f)
+ {
+ return f.as<framing::MessageTransferBody>()->getDestination();
+ }
}}