qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rob...@apache.org
Subject svn commit: r1229111 - in /qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server: queue/QueueRunner.java subscription/Subscription_0_10.java
Date Mon, 09 Jan 2012 12:30:30 GMT
Author: robbie
Date: Mon Jan  9 12:30:30 2012
New Revision: 1229111

URL: http://svn.apache.org/viewvc?rev=1229111&view=rev
Log:
NO-JIRA: remove unused code

Modified:
    qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java
    qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java

Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java?rev=1229111&r1=1229110&r2=1229111&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java
(original)
+++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRunner.java
Mon Jan  9 12:30:30 2012
@@ -56,7 +56,6 @@ public class QueueRunner implements Read
     private final AtomicLong _lastRunAgain = new AtomicLong();
     private final AtomicLong _lastRunTime = new AtomicLong();
 
-    private long _runs;
     private long _continues;
 
     public QueueRunner(SimpleAMQQueue queue)

Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java?rev=1229111&r1=1229110&r2=1229111&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java
(original)
+++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java
Mon Jan  9 12:30:30 2012
@@ -621,10 +621,6 @@ public class Subscription_0_10 implement
 
     }
 
-    public void flushCreditState()
-    {
-        flushCreditState(false);
-    }
     public void flushCreditState(boolean strict)
     {
         if(strict || !isSuspended() || _deferredMessageCredit >= 200



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message