diff options
Diffstat (limited to 'qpid/cpp/src/qpid/cluster/exp/EventHandler.cpp')
-rw-r--r-- | qpid/cpp/src/qpid/cluster/exp/EventHandler.cpp | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/cluster/exp/EventHandler.cpp b/qpid/cpp/src/qpid/cluster/exp/EventHandler.cpp index ed02d35d73..dc10548f80 100644 --- a/qpid/cpp/src/qpid/cluster/exp/EventHandler.cpp +++ b/qpid/cpp/src/qpid/cluster/exp/EventHandler.cpp @@ -64,15 +64,18 @@ void EventHandler::deliver( framing::AMQFrame frame; // FIXME aconway 2011-09-29: don't decode own frame bodies. Ignore based on channel. while (buf.available()) { + // FIXME aconway 2011-10-19: multi-version, skip unrecognized frames. frame.decode(buf); QPID_LOG(trace, "cluster: deliver on " << cpg.getName() << " from "<< PrettyId(sender, self) << ": " << frame); try { handle(frame); } catch (const std::exception& e) { - // Non-fatal error. Our state isn't compromized by receiving bad frames. - QPID_LOG(error, "cluster: error in deliver on " << cpg.getName() - << " from " << PrettyId(sender, self) << ": " << frame); + // FIXME aconway 2011-10-19: error handling. + QPID_LOG(error, "cluster: error in deliver on " << cpg.getName() + << " from " << PrettyId(sender, self) + << ": " << frame + << ": " << e.what()); } } } |