diff options
author | Alan Conway <aconway@apache.org> | 2007-11-28 20:17:55 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-11-28 20:17:55 +0000 |
commit | 04fb4fdba88145a473b9a3a56ac6fd531af89af2 (patch) | |
tree | 6f273099f9518b5c4201ce2fdd913f19b7aef77f /cpp/src/qpid/client/Dispatcher.cpp | |
parent | 42452eee5308e71a1363ca394827c6fbb1bd2234 (diff) | |
download | qpid-python-04fb4fdba88145a473b9a3a56ac6fd531af89af2.tar.gz |
Add unit_test.h to distribution.
Updated/removed sundry FIXME comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599128 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/Dispatcher.cpp')
-rw-r--r-- | cpp/src/qpid/client/Dispatcher.cpp | 17 |
1 files changed, 4 insertions, 13 deletions
diff --git a/cpp/src/qpid/client/Dispatcher.cpp b/cpp/src/qpid/client/Dispatcher.cpp index fd6a18b349..37fada45fb 100644 --- a/cpp/src/qpid/client/Dispatcher.cpp +++ b/cpp/src/qpid/client/Dispatcher.cpp @@ -75,20 +75,11 @@ void Dispatcher::run() if (content->isA<MessageTransferBody>()) { Message msg(*content, session); Subscriber::shared_ptr listener = find(msg.getDestination()); - if (!listener) { - // FIXME aconway 2007-11-07: Should close session & throw here? - QPID_LOG(error, "No message listener for " - << content->getMethod()); - } else { - listener->received(msg); - } + assert(listener); + listener->received(msg); } else { - if (handler.get()) { - handler->handle(*content); - } else { - // FIXME aconway 2007-11-07: Should close session & throw here? - QPID_LOG(error, "Unhandled method: " << content->getMethod()); - } + assert (handler.get()); + handler->handle(*content); } } } |