activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-5686
Date Tue, 24 Mar 2015 20:07:25 GMT
Repository: activemq
Updated Branches:
  refs/heads/master cdb60d74b -> e33b3f593


https://issues.apache.org/jira/browse/AMQ-5686

Call into the delegate for asyncAddTopicMessage to avoid a stack
overflow.

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

Branch: refs/heads/master
Commit: e33b3f5939c1b48a35df54eae13757f44a179650
Parents: cdb60d7
Author: Timothy Bish <tabish121@gmail.com>
Authored: Tue Mar 24 16:07:07 2015 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Tue Mar 24 16:07:07 2015 -0400

----------------------------------------------------------------------
 .../main/java/org/apache/activemq/store/ProxyMessageStore.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/e33b3f59/activemq-broker/src/main/java/org/apache/activemq/store/ProxyMessageStore.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/store/ProxyMessageStore.java
b/activemq-broker/src/main/java/org/apache/activemq/store/ProxyMessageStore.java
index 901c769..c9b2060 100755
--- a/activemq-broker/src/main/java/org/apache/activemq/store/ProxyMessageStore.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/store/ProxyMessageStore.java
@@ -17,7 +17,6 @@
 package org.apache.activemq.store;
 
 import java.io.IOException;
-import java.util.concurrent.Future;
 
 import org.apache.activemq.broker.ConnectionContext;
 import org.apache.activemq.command.ActiveMQDestination;
@@ -138,7 +137,7 @@ public class ProxyMessageStore implements MessageStore {
 
     @Override
     public ListenableFuture<Object> asyncAddTopicMessage(ConnectionContext context,
Message message, boolean canOptimizeHint) throws IOException {
-        return asyncAddTopicMessage(context,message,canOptimizeHint);
+        return delegate.asyncAddTopicMessage(context,message,canOptimizeHint);
     }
 
     @Override


Mime
View raw message