Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

handle Future correctly passed back from the store 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955221 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2010-06-16 12:49:24 +00:00
parent ddf228227c
commit 1999d948bb
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
View File

@ -419,7 +419,7 @@ public class Topic extends BaseDestination implements Task {
waitForSpace(context, systemUsage.getStoreUsage(), getStoreUsageHighWaterMark(), logMessage);
}
topicStore.asyncAddTopicMessage(context, message);
result = topicStore.asyncAddTopicMessage(context, message);
}
message.incrementReferenceCount();

3
activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
View File

@ -182,8 +182,7 @@ public class KahaDBTransactionStore implements TransactionStore {
@Override
public Future<Object> asyncAddTopicMessage(ConnectionContext context, Message message) throws IOException {
KahaDBTransactionStore.this.asyncAddTopicMessage(context, getDelegate(), message);
return AbstractMessageStore.FUTURE;
return KahaDBTransactionStore.this.asyncAddTopicMessage(context, getDelegate(), message);
}
@Override