Honour sync bit when processing L4 method

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@580266 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 8 insertions, 2 deletions

diff --git a/cpp/src/qpid/broker/SemanticHandler.cpp b/cpp/src/qpid/broker/SemanticHandler.cpp
index 0bb813ebfd..048c73c4b0 100644
--- a/cpp/src/qpid/broker/SemanticHandler.cpp
+++ b/cpp/src/qpid/broker/SemanticHandler.cpp
@@ -132,7 +132,10 @@ void SemanticHandler::handleCommand(framing::AMQMethodBody* method)
     } else if (v.hasResult()) {
         session.getProxy().getExecution().result(id.getValue(), v.getResult());
     }
-    //TODO: if (method->isSync()) { incoming.synch(id); sendCompletion(); }
+    if (method->isSync()) { 
+        incoming.sync(id); 
+        sendCompletion(); 
+    }
     //TODO: if window gets too large send unsolicited completion
 }
 
@@ -156,7 +159,10 @@ void SemanticHandler::handleContent(AMQFrame& frame)
         state.handle(msg);        
         msgBuilder.end();
         incoming.track(msg);
-        //TODO: if (msg.getMethod().isSync()) { incoming.synch(msg.getCommandId()); sendCompletion(); }
+        if (msg->getFrames().getMethod()->isSync()) { 
+            incoming.sync(msg->getCommandId()); 
+            sendCompletion(); 
+        }
     }
 }