activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [52/65] [abbrv] activemq-artemis git commit: fixing testsuite (the testuie broke in a lot of places after this fix now being reverted
Date Fri, 18 Mar 2016 01:42:41 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/8bd3aabb
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/8bd3aabb
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/8bd3aabb

Branch: refs/heads/refactor-openwire
Commit: 8bd3aabb61cd5ab52837d193a4972425858293fa
Parents: c596e85
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Fri Feb 26 11:14:54 2016 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Thu Mar 17 14:10:46 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/8bd3aabb/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