From 001d11d9e53ee2f9217bba412e5c7db141e0db11 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 24 Mar 2009 14:07:25 +0000 Subject: QPID-1771: fix as applied to branch as r757807. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757808 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/cluster/Decoder.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/cluster/Decoder.cpp') diff --git a/cpp/src/qpid/cluster/Decoder.cpp b/cpp/src/qpid/cluster/Decoder.cpp index 4de586d89f..b337ef43f4 100644 --- a/cpp/src/qpid/cluster/Decoder.cpp +++ b/cpp/src/qpid/cluster/Decoder.cpp @@ -47,12 +47,13 @@ void Decoder::decode(const EventHeader& eh, const char* data) { // We must give 1 unit read credit per event. // This event does not complete any frames so // send an empty frame with the read credit. - process(EventFrame(EventHeader(), framing::AMQFrame(), 1)); + process(EventFrame(eh, framing::AMQFrame(), 1)); } } void Decoder::process(const EventFrame& ef) { - if (ef.frame.getMethod() && ef.frame.getMethod()->isA()) + //need to check that this is not the empty frame mentioned above + if (ef.frame.getBody() && ef.frame.getMethod() && ef.frame.getMethod()->isA()) map.erase(ef.connectionId); callback(ef); } -- cgit v1.2.1