fixing testsuite (the testuie broke in a lot of places after this fix now being 
reverted


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/476ab2bb
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/476ab2bb
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/476ab2bb

Branch: refs/heads/refactor-openwire
Commit: 476ab2bbb5a73fcb8332e2483e41250847b0c7a4
Parents: 5564fd8
Author: Clebert Suconic <[email protected]>
Authored: Fri Feb 26 11:14:54 2016 -0500
Committer: Clebert Suconic <[email protected]>
Committed: Fri Mar 4 15:41:48 2016 -0500

----------------------------------------------------------------------
 .../core/protocol/openwire/amq/AMQServerConsumer.java       | 9 ---------
 1 file changed, 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/476ab2bb/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQServerConsumer.java
----------------------------------------------------------------------
diff --git 
a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQServerConsumer.java
 
b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQServerConsumer.java
index 34789b0..7215f64 100644
--- 
a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQServerConsumer.java
+++ 
b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQServerConsumer.java
@@ -187,13 +187,4 @@ public class AMQServerConsumer extends ServerConsumerImpl {
       }
    }
 
-   @Override
-   protected void updateDeliveryCountForCanceledRef(MessageReference ref, 
boolean failed) {
-      //activemq5 doesn't decrease the count
-      //when not failed.
-      if (failed) {
-         ref.decrementDeliveryCount();
-      }
-   }
-
 }

Reply via email to