summaryrefslogtreecommitdiff
path: root/qpid/java/systests/src
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2012-04-12 19:46:03 +0000
committerRobert Godfrey <rgodfrey@apache.org>2012-04-12 19:46:03 +0000
commitefad669d94b04a59d2b62581e607a3f6243cd63a (patch)
tree73c2c338d99072241f411e828b9b52b6868e21f2 /qpid/java/systests/src
parentc052ece2e23a226bfc713e5137f1e71ec4f2f90d (diff)
downloadqpid-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.java9
-rw-r--r--qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStoreFactory.java7
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