diff options
| author | Robert Gemmell <robbie@apache.org> | 2012-01-09 12:30:30 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2012-01-09 12:30:30 +0000 |
| commit | 178be0dc81bd0b974e840ca0566970887bb60289 (patch) | |
| tree | d97809bf6602588afd0352d59e48b45d94e7f734 /qpid/java | |
| parent | 229bd8f9260990d5353fcfa7ec0c20ad2c45c839 (diff) | |
| download | qpid-python-178be0dc81bd0b974e840ca0566970887bb60289.tar.gz | |
NO-JIRA: remove unused code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229111 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java | 1 | ||||
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java | 4 |
2 files changed, 0 insertions, 5 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java index a6cdb40d72..a092145958 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java @@ -56,7 +56,6 @@ public class QueueRunner implements ReadWriteRunnable private final AtomicLong _lastRunAgain = new AtomicLong(); private final AtomicLong _lastRunTime = new AtomicLong(); - private long _runs; private long _continues; public QueueRunner(SimpleAMQQueue queue) diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java index dea88c4776..3246dc0275 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java @@ -621,10 +621,6 @@ public class Subscription_0_10 implements Subscription, FlowCreditManager.FlowCr } - public void flushCreditState() - { - flushCreditState(false); - } public void flushCreditState(boolean strict) { if(strict || !isSuspended() || _deferredMessageCredit >= 200 |