diff options
Diffstat (limited to 'cpp/src/qpid/broker/SemanticState.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/SemanticState.cpp | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp index 2bc366dc86..085578295d 100644 --- a/cpp/src/qpid/broker/SemanticState.cpp +++ b/cpp/src/qpid/broker/SemanticState.cpp @@ -380,9 +380,13 @@ void SemanticState::requestDispatch() void SemanticState::requestDispatch(ConsumerImpl& c) { - if(c.isBlocked()) { - c.doOutput(); - } + if(c.isBlocked()) + outputTasks.activateOutput(); + // TODO aconway 2008-07-16: we could directly call + // c.doOutput(); + // since we are in the connections thread but for consistency + // activateOutput() will set it up to be called in the next write idle. + // Current cluster code depends on this, review cluster code to change. } void SemanticState::complete(DeliveryRecord& delivery) |