diff options
Diffstat (limited to 'cpp/src/qpid/broker/MessageAdapter.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/MessageAdapter.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/MessageAdapter.cpp b/cpp/src/qpid/broker/MessageAdapter.cpp index c0c1c4445a..acec2b2af6 100644 --- a/cpp/src/qpid/broker/MessageAdapter.cpp +++ b/cpp/src/qpid/broker/MessageAdapter.cpp @@ -67,4 +67,9 @@ namespace broker{ return b && b->getAcceptMode() == 0/*EXPLICIT == 0*/; } + uint8_t TransferAdapter::getPriority(const framing::FrameSet& f) + { + const framing::DeliveryProperties* p = f.getHeaders()->get<framing::DeliveryProperties>(); + return p ? p->getPriority() : 0; + } }} |