summaryrefslogtreecommitdiff
path: root/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
commit7661c82fc7aaca543582ef45582d87de3c5de5b7 (patch)
tree9de25825187c0a45df5880ce74e58befb6c4ec50 /cpp/src/qmf/engine/SequenceManager.cpp
parent576b578d61d0d31082587bf77a25a59da2ba738f (diff)
downloadqpid-python-7661c82fc7aaca543582ef45582d87de3c5de5b7.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/qpid@819819 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qmf/engine/SequenceManager.cpp')
-rw-r--r--cpp/src/qmf/engine/SequenceManager.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qmf/engine/SequenceManager.cpp b/cpp/src/qmf/engine/SequenceManager.cpp
index 3708105b46..4a4644a8b9 100644
--- a/cpp/src/qmf/engine/SequenceManager.cpp
+++ b/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);