Repository: activemq-artemis Updated Branches: refs/heads/ARTEMIS-780 ec1762b1c -> eaa61333b
Fix Constructor and @Override Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/eaa61333 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/eaa61333 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/eaa61333 Branch: refs/heads/ARTEMIS-780 Commit: eaa61333be07dd98055c86cb6dbd740510865337 Parents: ec1762b Author: Martyn Taylor <[email protected]> Authored: Tue Nov 1 10:42:54 2016 +0000 Committer: Martyn Taylor <[email protected]> Committed: Tue Nov 1 10:42:54 2016 +0000 ---------------------------------------------------------------------- .../persistence/impl/journal/AbstractJournalStorageManager.java | 1 + .../org/apache/activemq/artemis/core/server/impl/QueueImpl.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/eaa61333/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java ---------------------------------------------------------------------- diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java index b67cfa6..b9e91ec 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java @@ -1266,6 +1266,7 @@ public abstract class AbstractJournalStorageManager implements StorageManager { } } + @Override public void addAddressBinding(final long tx, final AddressInfo addressInfo) throws Exception { PersistentAddressBindingEncoding bindingEncoding = new PersistentAddressBindingEncoding(addressInfo.getName(), addressInfo.getRoutingType()); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/eaa61333/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java ---------------------------------------------------------------------- diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java index 2246c8e..6887637 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java @@ -344,7 +344,7 @@ public class QueueImpl implements Queue { final StorageManager storageManager, final HierarchicalRepository<AddressSettings> addressSettingsRepository, final Executor executor) { - this(id, address, name, filter, null, user, durable, temporary, autoCreated, null, null, scheduledExecutor, postOffice, storageManager, addressSettingsRepository, executor); + this(id, address, name, filter, pageSubscription, user, durable, temporary, autoCreated, null, null, scheduledExecutor, postOffice, storageManager, addressSettingsRepository, executor); } public QueueImpl(final long id,
