diff options
Diffstat (limited to 'qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java')
-rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java | 34 |
1 files changed, 24 insertions, 10 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java index 09d865cb05..38d3fb78fc 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java @@ -26,6 +26,8 @@ import org.apache.qpid.AMQStoreException; import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.framing.FieldTable; import org.apache.qpid.server.exchange.Exchange; +import org.apache.qpid.server.federation.Bridge; +import org.apache.qpid.server.federation.BrokerLink; import org.apache.qpid.server.logging.LogSubject; import org.apache.qpid.server.message.EnqueableMessage; import org.apache.qpid.server.queue.AMQQueue; @@ -45,8 +47,8 @@ public class SkeletonMessageStore implements MessageStore public void configureMessageStore(String name, MessageStoreRecoveryHandler recoveryHandler, - Configuration config, - LogSubject logSubject) throws Exception + TransactionLogRecoveryHandler tlogRecoveryHandler, + Configuration config, LogSubject logSubject) throws Exception { } @@ -98,14 +100,6 @@ public class SkeletonMessageStore implements MessageStore } - public void configureTransactionLog(String name, - TransactionLogRecoveryHandler recoveryHandler, - Configuration storeConfiguration, - LogSubject logSubject) throws Exception - { - - } - public Transaction newTransaction() { return new Transaction() @@ -162,4 +156,24 @@ public class SkeletonMessageStore implements MessageStore } + @Override + public void createBrokerLink(BrokerLink link) throws AMQStoreException + { + } + + @Override + public void deleteBrokerLink(BrokerLink link) throws AMQStoreException + { + } + + @Override + public void createBridge(Bridge bridge) throws AMQStoreException + { + } + + @Override + public void deleteBridge(Bridge bridge) throws AMQStoreException + { + } + } |