summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/Dispatcher.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-11-28 20:17:55 +0000
committerAlan Conway <aconway@apache.org>2007-11-28 20:17:55 +0000
commit04fb4fdba88145a473b9a3a56ac6fd531af89af2 (patch)
tree6f273099f9518b5c4201ce2fdd913f19b7aef77f /cpp/src/qpid/client/Dispatcher.cpp
parent42452eee5308e71a1363ca394827c6fbb1bd2234 (diff)
downloadqpid-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.cpp17
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);
}
}
}