diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-04-12 19:46:03 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-04-12 19:46:03 +0000 |
| commit | efad669d94b04a59d2b62581e607a3f6243cd63a (patch) | |
| tree | 73c2c338d99072241f411e828b9b52b6868e21f2 /qpid/java/systests/src | |
| parent | c052ece2e23a226bfc713e5137f1e71ec4f2f90d (diff) | |
| download | qpid-python-efad669d94b04a59d2b62581e607a3f6243cd63a.tar.gz | |
QPID-3917 : Refactor changes to MessageStore to use listeners and not decorators
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1325467 13f79535-47bb-0310-9956-ffa450edef68
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 |
