Removed dead code.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@675155 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 1 insertions, 13 deletions

diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp
index a4a40a03e8..2bc366dc86 100644
--- a/cpp/src/qpid/broker/SemanticState.cpp
+++ b/cpp/src/qpid/broker/SemanticState.cpp
@@ -62,7 +62,6 @@ SemanticState::SemanticState(DeliveryAdapter& da, SessionContext& ss)
       prefetchCount(0),
       tagGenerator("sgen"),
       dtxSelected(false),
-      flowActive(true),
       outputTasks(ss)
 {
     outstanding.reset();
@@ -288,7 +287,7 @@ bool SemanticState::ConsumerImpl::filter(intrusive_ptr<Message> msg)
 
 bool SemanticState::ConsumerImpl::accept(intrusive_ptr<Message> msg)
 {
-    blocked = !(filter(msg) && checkCredit(msg) && parent->flowActive && (!ackExpected || parent->checkPrefetch(msg)));
+    blocked = !(filter(msg) && checkCredit(msg) && (!ackExpected || parent->checkPrefetch(msg)));
     return !blocked;
 }
 
@@ -443,17 +442,6 @@ DeliveryId SemanticState::redeliver(QueuedMessage& msg, DeliveryToken::shared_pt
     return deliveryAdapter.deliver(msg, token);
 }
 
-void SemanticState::flow(bool active)
-{
-    bool requestDelivery(!flowActive && active);
-    flowActive = active;
-    if (requestDelivery) {
-        //there may be messages that can be now be delivered
-        requestDispatch();
-    }
-}
-
-
 SemanticState::ConsumerImpl& SemanticState::find(const std::string& destination)
 {
     ConsumerImplMap::iterator i = consumers.find(destination);