activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [49/60] [abbrv] activemq-artemis git commit: fixing testsuite (the testuie broke in a lot of places after this fix now being reverted
Date Wed, 16 Mar 2016 01:54:13 GMT
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/6b3d9d92
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6b3d9d92
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6b3d9d92

Branch: refs/heads/refactor-openwire
Commit: 6b3d9d924ffdacf7aa11c5090d16cca1ed473e97
Parents: 3333d9e
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Fri Feb 26 11:14:54 2016 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Tue Mar 15 20:45:29 2016 -0400

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


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b3d9d92/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 9e93b3d..b37e1cf 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
@@ -189,13 +189,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();
-      }
-   }
-
 }


Mime
View raw message