activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r957210 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java
Date Wed, 23 Jun 2010 14:11:19 GMT
Author: dejanb
Date: Wed Jun 23 14:11:19 2010
New Revision: 957210

URL: http://svn.apache.org/viewvc?rev=957210&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQ-2695 - counter fix

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java?rev=957210&r1=957209&r2=957210&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java
Wed Jun 23 14:11:19 2010
@@ -223,7 +223,6 @@ public class AMQTopicMessageStore extend
             this.store = store;
         }
 
-        @Override
         public boolean recoverMessageReference(MessageId ref) throws Exception {
             if (selectorExpression != null) {
                 MessageEvaluationContext ctx = new MessageEvaluationContext();
@@ -237,7 +236,6 @@ public class AMQTopicMessageStore extend
             return true;
         }
 
-        @Override
         public boolean recoverMessage(Message message) throws Exception {
             if (selectorExpression != null) {
                 MessageEvaluationContext ctx = new MessageEvaluationContext();
@@ -251,12 +249,10 @@ public class AMQTopicMessageStore extend
             return true;
         }
 
-        @Override
         public boolean isDuplicate(MessageId ref) {
             return false;
         }
 
-        @Override
         public boolean hasSpace() {
             return true;
         }



Mime
View raw message