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

Fix for https://issues.apache.org/activemq/browse/AMQ-1842 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@729942 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-12-29 16:50:53 +00:00
parent f42627054c
commit 30f41b9811
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kahadb/src/main/java/org/apache/kahadb/store/KahaDBStore.java
View File

@ -40,6 +40,7 @@ import org.apache.activemq.command.TransactionId;
import org.apache.activemq.command.XATransactionId; import org.apache.activemq.command.XATransactionId;
import org.apache.activemq.openwire.OpenWireFormat; import org.apache.activemq.openwire.OpenWireFormat;
import org.apache.activemq.protobuf.Buffer; import org.apache.activemq.protobuf.Buffer;
import org.apache.activemq.store.AbstractMessageStore;
import org.apache.activemq.store.MessageRecoveryListener; import org.apache.activemq.store.MessageRecoveryListener;
import org.apache.activemq.store.MessageStore; import org.apache.activemq.store.MessageStore;
import org.apache.activemq.store.PersistenceAdapter; import org.apache.activemq.store.PersistenceAdapter;
@ -118,12 +119,11 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter {
}; };
} }
public class KahaDBMessageStore implements MessageStore { public class KahaDBMessageStore extends AbstractMessageStore {
private final ActiveMQDestination destination;
protected KahaDestination dest; protected KahaDestination dest;
public KahaDBMessageStore(ActiveMQDestination destination) { public KahaDBMessageStore(ActiveMQDestination destination) {
this.destination = destination; super(destination);
this.dest = convert( destination ); this.dest = convert( destination );
} }