You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/01/17 19:27:45 UTC

[5/5] activemq-artemis git commit: This closes #965

This closes #965


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a79094b6
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a79094b6
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a79094b6

Branch: refs/heads/master
Commit: a79094b6e582f742a7fd06294f91b2ce09926490
Parents: bc8d673 68c4e50
Author: Clebert Suconic <cl...@apache.org>
Authored: Tue Jan 17 14:26:52 2017 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue Jan 17 14:26:52 2017 -0500

----------------------------------------------------------------------
 .../artemis/cli/commands/queue/CreateQueue.java |  2 +-
 .../cli/commands/queue/QueueAbstract.java       | 40 ++++++++++----------
 .../artemis/cli/commands/queue/UpdateQueue.java |  2 +-
 .../config/ActiveMQDefaultConfiguration.java    |  6 +--
 .../artemis/api/core/client/ClientSession.java  | 12 +++---
 .../core/management/ActiveMQServerControl.java  |  8 ++--
 .../api/core/management/QueueControl.java       |  2 +-
 .../core/client/impl/AddressQueryImpl.java      | 10 ++---
 .../core/client/impl/ClientSessionImpl.java     | 24 ++++++------
 .../core/client/impl/QueueQueryImpl.java        | 10 ++---
 .../core/impl/ActiveMQSessionContext.java       | 16 ++++----
 .../impl/wireformat/CreateQueueMessage_V2.java  | 26 ++++++-------
 .../impl/wireformat/CreateSessionMessage.java   |  2 +-
 .../SessionBindingQueryResponseMessage_V4.java  | 20 +++++-----
 .../SessionQueueQueryResponseMessage_V3.java    | 28 +++++++-------
 .../artemis/core/server/AddressQueryResult.java | 10 ++---
 .../artemis/core/server/QueueQueryResult.java   | 10 ++---
 .../spi/core/remoting/SessionContext.java       |  2 +-
 .../jms/client/ActiveMQMessageProducer.java     |  2 +-
 .../artemis/jms/client/ActiveMQSession.java     | 12 +++---
 .../jms/server/impl/JMSServerManagerImpl.java   |  2 +-
 .../artemis/junit/EmbeddedActiveMQResource.java |  2 +-
 .../client/HornetQClientSessionContext.java     |  2 +-
 .../core/config/CoreQueueConfiguration.java     | 20 +++++-----
 .../deployers/impl/FileConfigurationParser.java | 14 +++----
 .../impl/ActiveMQServerControlImpl.java         | 12 +++---
 .../core/management/impl/QueueControlImpl.java  |  4 +-
 .../core/persistence/QueueBindingInfo.java      |  4 +-
 .../journal/AbstractJournalStorageManager.java  |  2 +-
 .../codec/PersistentQueueBindingEncoding.java   | 22 +++++------
 .../artemis/core/postoffice/PostOffice.java     |  2 +-
 .../core/postoffice/impl/PostOfficeImpl.java    |  6 +--
 .../core/ServerSessionPacketHandler.java        |  4 +-
 .../artemis/core/server/ActiveMQServer.java     |  8 ++--
 .../artemis/core/server/BindingQueryResult.java | 10 ++---
 .../activemq/artemis/core/server/Queue.java     |  4 +-
 .../artemis/core/server/QueueConfig.java        | 26 ++++++-------
 .../artemis/core/server/ServerSession.java      |  2 +-
 .../core/server/impl/ActiveMQServerImpl.java    | 34 ++++++++---------
 .../impl/AutoCreatedQueueManagerImpl.java       |  2 +-
 .../core/server/impl/LastValueQueue.java        |  4 +-
 .../server/impl/PostOfficeJournalLoader.java    |  2 +-
 .../core/server/impl/QueueFactoryImpl.java      |  6 +--
 .../artemis/core/server/impl/QueueImpl.java     | 16 ++++----
 .../core/server/impl/ServerSessionImpl.java     | 10 ++---
 .../core/settings/impl/AddressSettings.java     | 34 ++++++++---------
 .../resources/schema/artemis-configuration.xsd  |  7 ++--
 .../core/config/impl/FileConfigurationTest.java | 12 +++---
 .../impl/ScheduledDeliveryHandlerTest.java      |  4 +-
 .../core/settings/AddressSettingsTest.java      |  2 +-
 .../resources/ConfigurationTest-full-config.xml |  8 ++--
 .../migrate/config/addressing/Address.java      |  2 +-
 .../test/resources/artemis-configuration.xsd    |  2 +-
 .../integration/addressing/AddressingTest.java  | 20 +++++-----
 .../tests/integration/cli/QueueCommandTest.java | 24 ++++++------
 .../integration/client/HangConsumerTest.java    |  6 +--
 .../cluster/distribution/ClusterTestBase.java   |  2 +-
 .../tests/integration/jms/JmsProducerTest.java  |  8 ++--
 .../jms/consumer/JmsConsumerTest.java           |  4 +-
 .../management/ActiveMQServerControlTest.java   |  6 +--
 .../ActiveMQServerControlUsingCoreTest.java     |  8 ++--
 .../management/QueueControlUsingCoreTest.java   |  4 +-
 .../jms/tests/message/MessageHeaderTest.java    |  4 +-
 .../activemq/artemis/common/AbstractAdmin.java  |  2 +-
 .../unit/core/postoffice/impl/FakeQueue.java    |  4 +-
 .../core/server/impl/fakes/FakePostOffice.java  |  2 +-
 66 files changed, 315 insertions(+), 314 deletions(-)
----------------------------------------------------------------------