diff options
Diffstat (limited to 'qpid/java/systests/src')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java | 9 | ||||
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStoreFactory.java | 7 |
2 files changed, 7 insertions, 9 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java index 2de8b7cdb7..69cc64c0d0 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java @@ -358,14 +358,15 @@ public class SlowMessageStore implements MessageStore } @Override - public void addEventListener(EventListener eventListener, Event event) + public void addEventListener(EventListener eventListener, Event... events) { - throw new UnsupportedOperationException(); + _realStore.addEventListener(eventListener, events); } @Override - public MessageStore getUnderlyingStore() + public String getStoreLocation() { - return _realStore.getUnderlyingStore(); + return _realStore.getStoreLocation(); } + } diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStoreFactory.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStoreFactory.java index 840362485e..6497a640d2 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStoreFactory.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStoreFactory.java @@ -19,16 +19,13 @@ */ package org.apache.qpid.server.store; -import org.apache.qpid.server.logging.LogSubject; -import org.apache.qpid.server.store.decorators.EventDecorator; - public class SlowMessageStoreFactory implements MessageStoreFactory { @Override - public MessageStore createMessageStore(LogSubject logSubject) + public MessageStore createMessageStore() { - return new EventDecorator(new SlowMessageStore()); + return new SlowMessageStore(); } @Override |
