You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kg...@apache.org on 2011/06/06 16:45:10 UTC
svn commit: r1132661 -
/qpid/branches/qpid-3079/qpid/cpp/src/qpid/broker/SessionState.cpp
Author: kgiusti
Date: Mon Jun 6 14:45:10 2011
New Revision: 1132661
URL: http://svn.apache.org/viewvc?rev=1132661&view=rev
Log:
checkpoint: fix setup of command callback
Modified:
qpid/branches/qpid-3079/qpid/cpp/src/qpid/broker/SessionState.cpp
Modified: qpid/branches/qpid-3079/qpid/cpp/src/qpid/broker/SessionState.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-3079/qpid/cpp/src/qpid/broker/SessionState.cpp?rev=1132661&r1=1132660&r2=1132661&view=diff
==============================================================================
--- qpid/branches/qpid-3079/qpid/cpp/src/qpid/broker/SessionState.cpp (original)
+++ qpid/branches/qpid-3079/qpid/cpp/src/qpid/broker/SessionState.cpp Mon Jun 6 14:45:10 2011
@@ -465,8 +465,8 @@ SessionState::IncompleteIngressMsgXfer::
// this routine is *only* invoked when the message needs to be asynchronously completed. Otherwise, ::completed()
// will be invoked directly. Thus, let the SessionState know this command is not going to complete immediately:
- pendingCmdCtxt = boost::intrusive_ptr<CommandContext>(new CommandContext(msg));
- boost::intrusive_ptr<qpid::broker::SessionContext::AsyncCommandContext> ctxt(pendingCmdCtxt);
+ cb->pendingCmdCtxt = boost::intrusive_ptr<CommandContext>(new CommandContext(msg));
+ boost::intrusive_ptr<qpid::broker::SessionContext::AsyncCommandContext> ctxt(cb->pendingCmdCtxt);
session->registerAsyncCommand(ctxt);
return cb;
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org