Call into the delegate for asyncAddTopicMessage to avoid a stack
overflow.
This commit is contained in:
Timothy Bish 2015-03-24 16:07:07 -04:00
parent cdb60d74b8
commit e33b3f5939
1 changed files with 1 additions and 2 deletions

View File

@ -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