diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/Protocol.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Protocol.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/broker/Protocol.cpp b/qpid/cpp/src/qpid/broker/Protocol.cpp index 90d4d7833f..e236698142 100644 --- a/qpid/cpp/src/qpid/broker/Protocol.cpp +++ b/qpid/cpp/src/qpid/broker/Protocol.cpp @@ -42,6 +42,7 @@ boost::intrusive_ptr<const qpid::broker::amqp_0_10::MessageTransfer> ProtocolReg for (Protocols::const_iterator i = protocols.begin(); !transfer && i != protocols.end(); ++i) { transfer = i->second->translate(m); } + if (!transfer) throw new Exception("Could not convert message into 0-10"); return transfer; } boost::shared_ptr<RecoverableMessage> ProtocolRegistry::recover(qpid::framing::Buffer& b) |