diff options
Diffstat (limited to 'cpp/src/qpid/broker/SemanticHandler.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/SemanticHandler.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/SemanticHandler.cpp b/cpp/src/qpid/broker/SemanticHandler.cpp index e1a8ae470d..3a20a2d41c 100644 --- a/cpp/src/qpid/broker/SemanticHandler.cpp +++ b/cpp/src/qpid/broker/SemanticHandler.cpp @@ -127,6 +127,7 @@ void SemanticHandler::handleCommand(framing::AMQMethodBody* method) if (!invoker.wasHandled()) { throw NotImplementedException("Not implemented"); } else if (invoker.hasResult()) { + Mutex::ScopedLock l(outLock); session.getProxy().getExecution().result(id.getValue(), invoker.getResult()); } if (method->isSync()) { |