diff options
| author | Keith Wall <kwall@apache.org> | 2014-03-28 17:14:25 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2014-03-28 17:14:25 +0000 |
| commit | 59f63df7016f77288fd5434e9e09557cd551eefd (patch) | |
| tree | a93b7059b600a5590f86552dd164ddfff296bb8a /qpid/java/broker-plugins/derby-store | |
| parent | e7b1fb49e4d5521c952f3ebed73384611c3ceb48 (diff) | |
| download | qpid-python-59f63df7016f77288fd5434e9e09557cd551eefd.tar.gz | |
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
Diffstat (limited to 'qpid/java/broker-plugins/derby-store')
| -rw-r--r-- | qpid/java/broker-plugins/derby-store/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java | 12 |
1 files changed, 1 insertions, 11 deletions
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(); } |