summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SemanticState.cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2013-06-04 14:27:40 +0000
committerAndrew Stitcher <astitcher@apache.org>2013-06-04 14:27:40 +0000
commit69aed09e38db75ccdd89c2146c066e60a6ab1011 (patch)
tree32f06aa8db5d813573e97c737d0036c1aa580904 /cpp/src/qpid/broker/SemanticState.cpp
parentb384e8073b2202db2142ebf9f9d9673483cde72f (diff)
downloadqpid-python-69aed09e38db75ccdd89c2146c066e60a6ab1011.tar.gz
QPID-4905: Tidy up
- Remove unused function getBuffered() of ConnectionOutputHandler - Stop SessionContext and AggregateOutput from needlessly implementing the OutputControl interface git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1489457 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SemanticState.cpp')
-rw-r--r--cpp/src/qpid/broker/SemanticState.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp
index 275886c6e3..1c74ff7325 100644
--- a/cpp/src/qpid/broker/SemanticState.cpp
+++ b/cpp/src/qpid/broker/SemanticState.cpp
@@ -506,7 +506,7 @@ void SemanticStateConsumerImpl::requestDispatch()
{
if (blocked) {
parent->session.getConnection().outputTasks.addOutputTask(this);
- parent->session.getConnection().outputTasks.activateOutput();
+ parent->session.getConnection().getOutput().activateOutput();
blocked = false;
}
}
@@ -736,7 +736,7 @@ void SemanticStateConsumerImpl::notify()
Mutex::ScopedLock l(lock);
if (notifyEnabled) {
parent->session.getConnection().outputTasks.addOutputTask(this);
- parent->session.getConnection().outputTasks.activateOutput();
+ parent->session.getConnection().getOutput().activateOutput();
}
}
@@ -806,7 +806,7 @@ void SemanticState::attached()
i->second->enableNotify();
session.getConnection().outputTasks.addOutputTask(i->second.get());
}
- session.getConnection().outputTasks.activateOutput();
+ session.getConnection().getOutput().activateOutput();
}
void SemanticState::detached()