summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qmf/engine/SequenceManager.cpp
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2009-09-29 03:21:49 +0000
committerTed Ross <tross@apache.org>2009-09-29 03:21:49 +0000
commit74fecbf7759d549824bf92266c51a3d5180b6b33 (patch)
tree74acb6cfb5cdd1a6f6602073ee37f72847e69c53 /qpid/cpp/src/qmf/engine/SequenceManager.cpp
parent425d83fc95aa42e155341aac20b814d4bf7bae08 (diff)
downloadqpid-python-74fecbf7759d549824bf92266c51a3d5180b6b33.tar.gz
QMF Engine updates:
- Connected console handler callbacks - Added string representations for a number of object classes - Added a feature that completes query requests sent to disconnected agents git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@819819 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qmf/engine/SequenceManager.cpp')
-rw-r--r--qpid/cpp/src/qmf/engine/SequenceManager.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/qmf/engine/SequenceManager.cpp b/qpid/cpp/src/qmf/engine/SequenceManager.cpp
index 3708105b46..4a4644a8b9 100644
--- a/qpid/cpp/src/qmf/engine/SequenceManager.cpp
+++ b/qpid/cpp/src/qmf/engine/SequenceManager.cpp
@@ -68,14 +68,14 @@ void SequenceManager::releaseAll()
contextMap.clear();
}
-void SequenceManager::dispatch(uint8_t opcode, uint32_t sequence, qpid::framing::Buffer& buffer)
+void SequenceManager::dispatch(uint8_t opcode, uint32_t sequence, const string& routingKey, qpid::framing::Buffer& buffer)
{
Mutex::ScopedLock _lock(lock);
bool done;
if (sequence == 0) {
if (unsolicitedContext.get() != 0) {
- done = unsolicitedContext->handleMessage(opcode, sequence, buffer);
+ done = unsolicitedContext->handleMessage(opcode, sequence, routingKey, buffer);
if (done)
unsolicitedContext->release();
}
@@ -85,7 +85,7 @@ void SequenceManager::dispatch(uint8_t opcode, uint32_t sequence, qpid::framing:
map<uint32_t, SequenceContext::Ptr>::iterator iter = contextMap.find(sequence);
if (iter != contextMap.end()) {
if (iter->second != 0) {
- done = iter->second->handleMessage(opcode, sequence, buffer);
+ done = iter->second->handleMessage(opcode, sequence, routingKey, buffer);
if (done) {
iter->second->release();
contextMap.erase(iter);