From 04fb4fdba88145a473b9a3a56ac6fd531af89af2 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 28 Nov 2007 20:17:55 +0000 Subject: 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 --- cpp/src/qpid/client/Dispatcher.cpp | 17 ++++------------- 1 file changed, 4 insertions(+), 13 deletions(-) (limited to 'cpp/src/qpid/client/Dispatcher.cpp') 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()) { 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); } } } -- cgit v1.2.1