This closes #2198
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/756609f6 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/756609f6 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/756609f6 Branch: refs/heads/master Commit: 756609f6a67bfbe546bc9d748d7278be296d4bdd Parents: f0c1362 8a9835a Author: Clebert Suconic <[email protected]> Authored: Tue Jul 31 12:12:00 2018 -0400 Committer: Clebert Suconic <[email protected]> Committed: Tue Jul 31 12:12:00 2018 -0400 ---------------------------------------------------------------------- .../activemq/artemis/utils/BooleanUtil.java | 28 +++ .../config/ActiveMQDefaultConfiguration.java | 12 + .../core/management/ActiveMQServerControl.java | 61 +++++ .../core/config/CoreQueueConfiguration.java | 52 ++++- .../deployers/impl/FileConfigurationParser.java | 20 +- .../impl/ActiveMQServerControlImpl.java | 33 ++- .../core/persistence/QueueBindingInfo.java | 8 + .../journal/AbstractJournalStorageManager.java | 2 +- .../codec/PersistentQueueBindingEncoding.java | 48 +++- .../artemis/core/postoffice/PostOffice.java | 2 + .../core/postoffice/impl/PostOfficeImpl.java | 10 + .../artemis/core/server/ActiveMQServer.java | 27 +++ .../activemq/artemis/core/server/Queue.java | 14 ++ .../artemis/core/server/QueueConfig.java | 39 +++- .../core/server/impl/ActiveMQServerImpl.java | 125 +++++++++-- .../core/server/impl/LastValueQueue.java | 4 +- .../server/impl/PostOfficeJournalLoader.java | 2 + .../core/server/impl/QueueFactoryImpl.java | 6 +- .../artemis/core/server/impl/QueueImpl.java | 174 ++++++++++++--- .../core/settings/impl/AddressSettings.java | 70 +++++- .../resources/schema/artemis-configuration.xsd | 20 ++ .../core/config/impl/FileConfigurationTest.java | 10 +- .../impl/ScheduledDeliveryHandlerTest.java | 35 +++ .../test/resources/artemis-configuration.xsd | 20 ++ .../jms/client/ConsumerDelayDispatchTest.java | 223 +++++++++++++++++++ .../ActiveMQServerControlUsingCoreTest.java | 10 + .../persistence/QueueConfigRestartTest.java | 46 ++++ .../unit/core/postoffice/impl/FakeQueue.java | 35 +++ .../core/server/impl/fakes/FakePostOffice.java | 2 + 29 files changed, 1064 insertions(+), 74 deletions(-) ----------------------------------------------------------------------
