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.cpp23
1 files changed, 14 insertions, 9 deletions
diff --git a/cpp/src/qpid/broker/MessageAdapter.cpp b/cpp/src/qpid/broker/MessageAdapter.cpp
index 0e99d923d4..013e2c91ac 100644
--- a/cpp/src/qpid/broker/MessageAdapter.cpp
+++ b/cpp/src/qpid/broker/MessageAdapter.cpp
@@ -21,6 +21,11 @@
#include "MessageAdapter.h"
+#include "qpid/framing/DeliveryProperties.h"
+#include "qpid/framing/MessageProperties.h"
+#include "qpid/framing/MessageTransferBody.h"
+#include "qpid/framing/MessageXTransferBody.h"
+
namespace {
const std::string empty;
}
@@ -30,13 +35,13 @@ namespace broker{
std::string TransferAdapter::getRoutingKey(const framing::FrameSet& f)
{
- const framing::DeliveryProperties010* p = f.getHeaders()->get<framing::DeliveryProperties010>();
+ const framing::DeliveryProperties* p = f.getHeaders()->get<framing::DeliveryProperties>();
return p ? p->getRoutingKey() : empty;
}
std::string TransferAdapter::getExchange(const framing::FrameSet& f)
{
- return f.as<framing::Message010TransferBody>()->getDestination();
+ return f.as<framing::MessageTransferBody>()->getDestination();
}
bool TransferAdapter::isImmediate(const framing::FrameSet&)
@@ -47,42 +52,42 @@ namespace broker{
const framing::FieldTable* TransferAdapter::getApplicationHeaders(const framing::FrameSet& f)
{
- const framing::MessageProperties010* p = f.getHeaders()->get<framing::MessageProperties010>();
+ const framing::MessageProperties* p = f.getHeaders()->get<framing::MessageProperties>();
return p ? &(p->getApplicationHeaders()) : 0;
}
bool TransferAdapter::isPersistent(const framing::FrameSet& f)
{
- const framing::DeliveryProperties010* p = f.getHeaders()->get<framing::DeliveryProperties010>();
+ const framing::DeliveryProperties* p = f.getHeaders()->get<framing::DeliveryProperties>();
return p && p->getDeliveryMode() == 2;
}
bool TransferAdapter::requiresAccept(const framing::FrameSet& f)
{
- const framing::Message010TransferBody* b = f.as<framing::Message010TransferBody>();
+ const framing::MessageTransferBody* b = f.as<framing::MessageTransferBody>();
return b && b->getAcceptMode() == 0/*EXPLICIT == 0*/;
}
std::string PreviewAdapter::getExchange(const framing::FrameSet& f)
{
- return f.as<framing::MessageTransferBody>()->getDestination();
+ return f.as<framing::MessageXTransferBody>()->getDestination();
}
std::string PreviewAdapter::getRoutingKey(const framing::FrameSet& f)
{
- const framing::DeliveryProperties* p = f.getHeaders()->get<framing::DeliveryProperties>();
+ const framing::PreviewDeliveryProperties* p = f.getHeaders()->get<framing::PreviewDeliveryProperties>();
return p ? p->getRoutingKey() : empty;
}
const framing::FieldTable* PreviewAdapter::getApplicationHeaders(const framing::FrameSet& f)
{
- const framing::MessageProperties* p = f.getHeaders()->get<framing::MessageProperties>();
+ const framing::PreviewMessageProperties* p = f.getHeaders()->get<framing::PreviewMessageProperties>();
return p ? &(p->getApplicationHeaders()) : 0;
}
bool PreviewAdapter::isPersistent(const framing::FrameSet& f)
{
- const framing::DeliveryProperties* p = f.getHeaders()->get<framing::DeliveryProperties>();
+ const framing::PreviewDeliveryProperties* p = f.getHeaders()->get<framing::PreviewDeliveryProperties>();
return p && p->getDeliveryMode() == 2;
}