From 59f63df7016f77288fd5434e9e09557cd551eefd Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Fri, 28 Mar 2014 17:14:25 +0000 Subject: NO-JIRA: Make the MessageStore and DurableConfigurationStore stateless. This changes removes the StateManager and delegates the operational logging (open/close) messages to the vhost. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-bdb-ha2@1582835 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/server/store/derby/DerbyMessageStore.java | 12 +----------- 1 file changed, 1 insertion(+), 11 deletions(-) (limited to 'qpid/java/broker-plugins/derby-store') diff --git a/qpid/java/broker-plugins/derby-store/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java b/qpid/java/broker-plugins/derby-store/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java index 2c2938cb01..9202672ea6 100644 --- a/qpid/java/broker-plugins/derby-store/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java +++ b/qpid/java/broker-plugins/derby-store/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java @@ -38,7 +38,6 @@ import org.apache.log4j.Logger; import org.apache.qpid.server.store.AbstractJDBCMessageStore; import org.apache.qpid.server.store.DurableConfigurationStore; import org.apache.qpid.server.store.Event; -import org.apache.qpid.server.store.EventListener; import org.apache.qpid.server.store.MessageStore; import org.apache.qpid.server.store.StoreException; import org.apache.qpid.util.FileUtils; @@ -168,16 +167,7 @@ public class DerbyMessageStore extends AbstractJDBCMessageStore implements Messa //FIXME this the _vhost name should not be added here, but derby wont use an empty directory as was possibly just created. _connectionURL = "jdbc:derby" + (databasePath.equals(MEMORY_STORE_LOCATION) ? databasePath: ":" + databasePath+ "/") + name + ";create=true"; - - - _eventManager.addEventListener(new EventListener() - { - @Override - public void event(Event event) - { - setInitialSize(); - } - }, Event.BEFORE_ACTIVATE); + setInitialSize(); } -- cgit v1.2.1