This is an automated email from the ASF dual-hosted git repository.
robbie pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
from e3768fea01 ARTEMIS-5228: Update to Netty 4.1.118 (and netty-tcnative
test dep to 2.0.70.Final)
new e7f48fe359 ARTEMIS-5293 use Files.readString() & Files.writeString()
where possible
new 3d7970d717 ARTEMIS-5294 use String.repeat() where possible
new d587a077f6 ARTEMIS-5295 use switch expressions where possible
new 0082dfb01d ARTEMIS-5278 use pattern matching for instanceof
new 27feb5d54e ARTEMIS-5297 remove duplicate if statements
new 8ee9e7822e ARTEMIS-5297 fix typo in condition
new c5479cb856 ARTEMIS-5297 combine redundant conditionals
new 7aea998bb7 ARTEMIS-5297 fix duplicate conditions
new 5e080aa369 ARTEMIS-5297 extract common code from if branches
new 009f909b41 ARTEMIS-5299 prefer StringBuilder over StringBuffer
new 31cb265c89 ARTEMIS-5294 more cases for String.repeat()
new 9eba887142 ARTEMIS-5298 refactor RandomUtil
new 957ebcbb65 ARTEMIS-5306 remove unused class
The 13 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../activemq/artemis/cli/commands/Create.java | 23 +-
.../artemis/cli/commands/InputAbstract.java | 14 +-
.../cli/commands/address/AddressAbstract.java | 2 +-
.../artemis/cli/commands/helper/HelperCreate.java | 8 +-
.../cli/commands/messages/ProducerThread.java | 2 +-
.../cli/commands/tools/xml/XMLMessageImporter.java | 31 +-
.../activemq/artemis/util/JVMArgumentParser.java | 2 +-
.../cli/commands/messages/ProducerThreadTest.java | 6 +-
.../apache/activemq/cli/test/CliProducerTest.java | 8 +-
.../activemq/cli/test/ClusterVerifyTest.java | 20 +-
.../apache/activemq/cli/test/FileBrokerTest.java | 19 +-
.../activemq/cli/test/MessageSerializerTest.java | 4 +-
.../apache/activemq/cli/test/StringGenerator.java | 46 ---
.../artemis/api/core/DisconnectReason.java | 25 +-
.../activemq/artemis/api/core/RoutingType.java | 26 +-
.../apache/activemq/artemis/utils/ByteUtil.java | 18 +-
.../apache/activemq/artemis/utils/RandomUtil.java | 51 ++-
.../activemq/artemis/utils/SelectorTranslator.java | 10 +-
.../activemq/artemis/utils/SpawnedVMSupport.java | 2 -
.../apache/activemq/artemis/utils/TableOut.java | 11 +-
.../org/apache/activemq/artemis/utils/UUID.java | 2 +-
.../activemq/artemis/utils/bean/MetaBean.java | 4 +-
.../artemis/utils/collections/LongHashSet.java | 3 +-
.../activemq/artemis/utils/uri/URISchema.java | 8 +-
.../artemis/api/core/QueueConfigurationTest.java | 14 +-
.../artemis/utils/ConcurrentHashSetTest.java | 2 +-
.../utils/TypedPropertiesConversionTest.java | 4 +-
.../artemis/utils/TypedPropertiesTest.java | 70 ++--
.../activemq/artemis/utils/bean/MetaBeanTest.java | 2 +-
.../core/client/impl/ServerLocatorImpl.java | 10 +-
.../core/config/FederationConfiguration.java | 6 +-
.../FederationAddressPolicyConfiguration.java | 6 +-
.../config/federation/FederationPolicySet.java | 3 +-
.../FederationQueuePolicyConfiguration.java | 6 +-
.../federation/FederationStreamConfiguration.java | 3 +-
.../FederationTransformerConfiguration.java | 3 +-
.../artemis/core/message/impl/CoreMessage.java | 17 +-
.../protocol/core/impl/ActiveMQSessionContext.java | 8 +-
.../core/protocol/core/impl/ChannelImpl.java | 71 ++--
.../core/protocol/core/impl/PacketImpl.java | 3 +-
.../impl/wireformat/ActiveMQExceptionMessage.java | 3 +-
.../wireformat/ActiveMQExceptionMessage_V2.java | 3 +-
.../core/impl/wireformat/CheckFailoverMessage.java | 6 +-
.../impl/wireformat/CheckFailoverReplyMessage.java | 6 +-
.../wireformat/ClusterTopologyChangeMessage.java | 15 +-
.../ClusterTopologyChangeMessage_V2.java | 19 +-
.../ClusterTopologyChangeMessage_V3.java | 21 +-
.../ClusterTopologyChangeMessage_V4.java | 9 +-
.../core/impl/wireformat/CreateAddressMessage.java | 13 +-
.../core/impl/wireformat/CreateQueueMessage.java | 17 +-
.../impl/wireformat/CreateQueueMessage_V2.java | 45 ++-
.../core/impl/wireformat/CreateSessionMessage.java | 31 +-
.../impl/wireformat/CreateSessionMessage_V2.java | 9 +-
.../wireformat/CreateSessionResponseMessage.java | 9 +-
.../impl/wireformat/CreateSharedQueueMessage.java | 17 +-
.../wireformat/CreateSharedQueueMessage_V2.java | 53 ++-
.../impl/wireformat/DisconnectConsumerMessage.java | 6 +-
.../DisconnectConsumerWithKillMessage.java | 6 +-
.../core/impl/wireformat/DisconnectMessage.java | 9 +-
.../core/impl/wireformat/DisconnectMessage_V2.java | 11 +-
.../core/impl/wireformat/DisconnectMessage_V3.java | 15 +-
.../impl/wireformat/NullResponseMessage_V2.java | 3 +-
.../impl/wireformat/PacketsConfirmedMessage.java | 3 +-
.../core/protocol/core/impl/wireformat/Ping.java | 9 +-
.../impl/wireformat/ReattachSessionMessage.java | 11 +-
.../wireformat/ReattachSessionResponseMessage.java | 11 +-
.../core/impl/wireformat/RollbackMessage.java | 9 +-
.../impl/wireformat/SessionAcknowledgeMessage.java | 13 +-
.../impl/wireformat/SessionAddMetaDataMessage.java | 11 +-
.../wireformat/SessionAddMetaDataMessageV2.java | 15 +-
.../wireformat/SessionBindingQueryMessage.java | 11 +-
.../SessionBindingQueryResponseMessage.java | 11 +-
.../SessionBindingQueryResponseMessage_V2.java | 9 +-
.../SessionBindingQueryResponseMessage_V3.java | 9 +-
.../SessionBindingQueryResponseMessage_V4.java | 23 +-
.../SessionBindingQueryResponseMessage_V5.java | 11 +-
.../impl/wireformat/SessionCommitMessage_V2.java | 3 +-
.../wireformat/SessionConsumerCloseMessage.java | 3 +-
.../SessionConsumerFlowCreditMessage.java | 3 +-
.../wireformat/SessionContinuationMessage.java | 11 +-
.../wireformat/SessionCreateConsumerMessage.java | 19 +-
.../impl/wireformat/SessionDeleteQueueMessage.java | 9 +-
.../core/impl/wireformat/SessionExpireMessage.java | 11 +-
.../wireformat/SessionForceConsumerDelivery.java | 11 +-
.../SessionIndividualAcknowledgeMessage.java | 13 +-
.../SessionProducerCreditsFailMessage.java | 11 +-
.../wireformat/SessionProducerCreditsMessage.java | 11 +-
.../impl/wireformat/SessionQueueQueryMessage.java | 9 +-
.../SessionQueueQueryResponseMessage.java | 23 +-
.../SessionQueueQueryResponseMessage_V2.java | 9 +-
.../SessionQueueQueryResponseMessage_V3.java | 49 ++-
.../SessionReceiveContinuationMessage.java | 9 +-
.../wireformat/SessionReceiveLargeMessage.java | 15 +-
.../impl/wireformat/SessionReceiveMessage.java | 13 +-
.../SessionRequestProducerCreditsMessage.java | 11 +-
.../wireformat/SessionSendContinuationMessage.java | 15 +-
.../SessionSendContinuationMessage_V2.java | 19 +-
.../impl/wireformat/SessionSendLargeMessage.java | 9 +-
.../core/impl/wireformat/SessionSendMessage.java | 9 +-
.../impl/wireformat/SessionSendMessage_V2.java | 11 +-
.../wireformat/SessionXAAfterFailedMessage.java | 9 +-
.../impl/wireformat/SessionXACommitMessage.java | 3 +-
.../core/impl/wireformat/SessionXAEndMessage.java | 3 +-
.../impl/wireformat/SessionXAForgetMessage.java | 9 +-
.../SessionXAGetInDoubtXidsResponseMessage.java | 11 +-
.../SessionXAGetTimeoutResponseMessage.java | 9 +-
.../core/impl/wireformat/SessionXAJoinMessage.java | 9 +-
.../impl/wireformat/SessionXAPrepareMessage.java | 9 +-
.../impl/wireformat/SessionXAResponseMessage.java | 15 +-
.../wireformat/SessionXAResponseMessage_V2.java | 15 +-
.../impl/wireformat/SessionXAResumeMessage.java | 9 +-
.../impl/wireformat/SessionXARollbackMessage.java | 9 +-
.../wireformat/SessionXASetTimeoutMessage.java | 9 +-
.../SessionXASetTimeoutResponseMessage.java | 9 +-
.../impl/wireformat/SessionXAStartMessage.java | 9 +-
.../SubscribeClusterTopologyUpdatesMessage.java | 9 +-
.../SubscribeClusterTopologyUpdatesMessageV2.java | 9 +-
.../core/remoting/impl/netty/NettyConnector.java | 16 +-
.../activemq/artemis/core/security/Role.java | 2 +-
.../server/ComponentConfigurationRoutingType.java | 38 +-
.../artemis/core/transaction/impl/XidImpl.java | 11 +-
.../artemis/core/version/impl/VersionImpl.java | 3 +-
.../activemq/artemis/reader/StreamMessageUtil.java | 160 ++++----
.../activemq/artemis/utils/VersionLoader.java | 2 +-
.../org/apache/activemq/artemis/utils/XMLUtil.java | 10 +-
.../artemis/jdbc/store/drivers/JDBCUtils.java | 4 +-
.../activemq/artemis/api/jms/JMSFactoryType.java | 64 +---
.../artemis/jms/client/ActiveMQDestination.java | 78 ++--
.../artemis/jms/client/ActiveMQMessage.java | 2 +-
.../activemq/artemis/jms/client/ActiveMQQueue.java | 4 +-
.../artemis/jms/client/ActiveMQSession.java | 12 +-
.../artemis/jms/client/ActiveMQTemporaryQueue.java | 4 +-
.../artemis/jms/client/ActiveMQTemporaryTopic.java | 4 +-
.../activemq/artemis/jms/client/ActiveMQTopic.java | 4 +-
.../artemis/jms/client/JMSExceptionHelper.java | 43 +--
.../artemis/uri/ConnectionFactoryURITest.java | 4 +-
.../artemis/jms/bridge/impl/JMSBridgeImpl.java | 2 +-
.../jms/persistence/config/PersistedType.java | 32 +-
.../jms/server/impl/JMSServerManagerImpl.java | 50 ++-
.../jms/transaction/JMSTransactionDetail.java | 28 +-
.../activemq/artemis/core/io/RunnableCallback.java | 66 ----
.../activemq/artemis/core/journal/RecordInfo.java | 3 +-
.../artemis/core/journal/impl/JournalImpl.java | 43 +--
.../zookeeper/CuratorDistributedLockManager.java | 14 +-
.../processor/LogAnnotationProcessor.java | 53 +--
.../artemis/maven/ArtemisCreatePlugin.java | 16 +-
.../artemis/maven/ArtemisDependencyDocPlugin.java | 3 +-
.../artemis/maven/ArtemisDependencyScanPlugin.java | 8 +-
.../artemis/protocol/amqp/broker/AMQPMessage.java | 13 +-
.../protocol/amqp/broker/AMQPStandardMessage.java | 26 +-
.../federation/AMQPFederationEventSupport.java | 8 +-
.../AMQPFederationGenericConsumerInfo.java | 4 +-
.../federation/AMQPFederationPolicySupport.java | 8 +-
.../connect/mirror/AMQPMirrorControllerTarget.java | 6 +-
.../amqp/converter/AMQPMessageSupport.java | 12 +-
.../coreWrapper/CoreBytesMessageWrapper.java | 17 +-
.../converter/coreWrapper/CoreMessageWrapper.java | 22 +-
.../coreWrapper/CoreObjectMessageWrapper.java | 14 +-
.../coreWrapper/CoreStreamMessageWrapper.java | 14 +-
.../amqp/proton/AMQPConnectionContext.java | 3 +-
.../proton/AMQPTunneledCoreLargeMessageReader.java | 16 +-
.../artemis/protocol/amqp/proton/AmqpSupport.java | 3 +-
.../amqp/proton/ProtonAbstractReceiver.java | 3 +-
.../artemis/protocol/amqp/util/NettyReadable.java | 3 +-
.../message/JMSMappingOutboundTransformerTest.java | 13 +-
.../core/protocol/mqtt/MQTTProtocolManager.java | 3 +-
.../core/protocol/mqtt/MQTTSessionState.java | 32 +-
.../artemis/core/protocol/mqtt/MQTTVersion.java | 32 +-
.../artemis/core/protocol/mqtt/MQTTUtilTest.java | 8 +-
.../artemis/core/protocol/mqtt/StateSerDeTest.java | 4 +-
.../core/protocol/openwire/OpenWireConnection.java | 3 +-
.../openwire/OpenWireMessageConverter.java | 72 ++--
.../protocol/openwire/OpenWireProtocolManager.java | 2 +-
.../openwire/OpenWireMessageConverterTest.java | 10 +-
.../openwire/amq/OpenWireProtocolManagerTest.java | 4 +-
.../artemis/ra/ActiveMQRASessionFactoryImpl.java | 29 +-
.../artemis/ra/ActiveMQResourceAdapter.java | 17 +-
.../artemis/ra/inflow/ActiveMQActivation.java | 12 +-
.../artemis/ra/inflow/ActiveMQActivationSpec.java | 32 +-
.../inflow/ActiveMQActivationValidationUtils.java | 11 +-
.../selector/filter/ArithmeticExpression.java | 39 +-
.../selector/filter/ComparisonExpression.java | 4 +-
.../selector/filter/ConstantExpression.java | 2 +-
.../artemis/selector/filter/UnaryExpression.java | 2 +-
.../artemis/core/config/WildcardConfiguration.java | 4 +-
.../AMQPFederationAddressPolicyElement.java | 8 +-
.../AMQPFederationQueuePolicyElement.java | 8 +-
.../core/config/impl/ConfigurationImpl.java | 33 +-
.../management/impl/ActiveMQServerControlImpl.java | 3 +-
.../core/management/impl/QueueControlImpl.java | 3 +-
.../core/management/impl/view/ConsumerView.java | 70 ++--
.../core/management/impl/view/ProducerView.java | 37 +-
.../core/management/impl/view/QueueView.java | 106 ++----
.../core/management/impl/view/SessionView.java | 31 +-
.../view/predicate/ActiveMQFilterPredicate.java | 88 ++---
.../view/predicate/ConnectionFilterPredicate.java | 35 +-
.../view/predicate/ConsumerFilterPredicate.java | 61 ++-
.../view/predicate/ProducerFilterPredicate.java | 40 +-
.../view/predicate/SessionFilterPredicate.java | 30 +-
.../activemq/artemis/core/paging/impl/Page.java | 6 +-
.../artemis/core/paging/impl/PageReadWriter.java | 3 +-
.../artemis/core/paging/impl/PagedMessageImpl.java | 15 +-
.../persistence/impl/journal/DescribeJournal.java | 17 +-
.../artemis/core/postoffice/impl/BindingsImpl.java | 3 +-
.../artemis/core/protocol/ServerPacketDecoder.java | 19 +-
.../impl/wireformat/BackupRegistrationMessage.java | 3 +-
.../core/impl/wireformat/NodeAnnounceMessage.java | 3 +-
.../core/impl/wireformat/QuorumVoteMessage.java | 8 +-
.../impl/wireformat/ReplicationAddMessage.java | 3 +-
.../impl/wireformat/ReplicationAddTXMessage.java | 3 +-
.../impl/wireformat/ReplicationCommitMessage.java | 3 +-
.../impl/wireformat/ReplicationDeleteMessage.java | 3 +-
.../ReplicationLargeMessageWriteMessage.java | 3 +-
.../impl/wireformat/ReplicationPrepareMessage.java | 3 +-
.../wireformat/ReplicationResponseMessageV2.java | 6 +-
.../wireformat/ReplicationStartSyncMessage.java | 17 +-
.../wireformat/ReplicationSyncFileMessage.java | 3 +-
.../remoting/impl/netty/HttpAcceptorHandler.java | 6 +-
.../core/replication/ReplicationEndpoint.java | 3 +-
.../core/replication/ReplicationManager.java | 25 +-
.../activemq/artemis/core/server/JournalType.java | 22 +-
.../activemq/artemis/core/server/QueueConfig.java | 2 -
.../address/FederatedAddressConsumerKey.java | 3 +-
.../queue/FederatedQueueConsumerKey.java | 3 +-
.../artemis/core/server/impl/AckReason.java | 20 +-
.../core/server/impl/ActiveMQServerImpl.java | 103 +++--
.../artemis/core/server/impl/AddressInfo.java | 30 +-
.../artemis/core/server/impl/QueueImpl.java | 6 +-
.../core/server/impl/ServerConsumerImpl.java | 3 +-
.../core/server/impl/ServerSessionImpl.java | 12 +-
.../server/impl/jdbc/JdbcSharedStateManager.java | 38 +-
.../websocket/WebSocketFrameEncoderType.java | 13 +-
.../artemis/core/server/routing/KeyType.java | 32 +-
.../artemis/core/settings/impl/DeletionPolicy.java | 13 +-
.../core/settings/impl/SlowConsumerPolicy.java | 13 +-
.../impl/SlowConsumerThresholdMeasurementUnit.java | 38 +-
.../transaction/impl/CoreTransactionDetail.java | 28 +-
.../spi/core/protocol/EmbedMessageUtil.java | 13 +-
.../artemis/spi/core/security/scram/SCRAM.java | 33 +-
.../core/config/WildcardConfigurationTest.java | 2 +-
.../config/impl/AbstractConfigurationTestBase.java | 32 +-
.../core/config/impl/ConfigurationImplTest.java | 22 +-
.../artemis/core/config/impl/ValidatorsTest.java | 8 +-
.../artemis/core/filter/impl/FilterTest.java | 2 +-
.../management/impl/AcceptorControlImplTest.java | 6 +-
.../impl/view/predicate/PredicateTest.java | 8 +-
.../impl/journal/AddressBindingEncodingTest.java | 2 +-
.../impl/journal/QueueBindingEncodingTest.java | 12 +-
.../core/security/impl/SecurityStoreImplTest.java | 10 +-
.../core/security/jaas/NoCacheLoginModule.java | 2 +-
.../impl/ClusterConnectionImplMockTest.java | 2 +-
.../core/server/impl/AdressInfoJSonTest.java | 2 +-
.../ArtemisRbacMBeanServerBuilderTest.java | 4 +-
.../artemis/tests/util/SimpleStringTest.java | 4 +-
.../xa/recovery/ActiveMQXAResourceWrapper.java | 22 +-
.../tests/extensions/ThreadLeakCheckDelegate.java | 2 -
.../artemiswrapper/OpenwireArtemisBaseTest.java | 6 +-
.../activemq/command/ActiveMQMapMessageTest.java | 2 +-
.../command/ActiveMQStreamMessageTest.java | 2 +-
.../activemq/test/JmsSendReceiveTestSupport.java | 6 +-
.../activemq/transport/udp/UdpTestSupport.java | 6 +-
.../stomp/util/AbstractClientStompFrame.java | 4 +-
.../stomp/util/StompFrameFactoryV11.java | 2 +-
.../stomp/util/StompFrameFactoryV12.java | 2 +-
.../artemis/tests/util/ActiveMQTestBase.java | 38 +-
.../activemq/artemis/tests/util/RandomUtil.java | 28 --
.../apache/activemq/artemis/utils/ExecuteUtil.java | 2 +-
.../activemq/transport/amqp/AmqpSupport.java | 3 +-
.../transport/amqp/client/AmqpMessage.java | 3 +-
.../amqp/client/sasl/CramMD5Mechanism.java | 2 +-
.../transport/amqp/client/util/PropertyUtil.java | 2 +-
.../amqp/client/util/StringArrayConverter.java | 2 +-
.../tests/compatibility/base/ClasspathBase.java | 6 +-
.../activemq/artemis/tests/db/common/Database.java | 13 +-
.../tests/db/common/ParameterDBTestBase.java | 15 +-
.../RealServerDatabaseLargeMessageTest.java | 2 +-
.../artemis/tests/db/paging/GlobalPagingTest.java | 8 +-
.../artemis/tests/db/paging/PageSizeTest.java | 23 +-
.../artemis/tests/db/paging/PagingTest.java | 8 +-
.../artemis/tests/db/paging/PrintDataTest.java | 2 +-
.../db/paging/RealServerDatabasePagingTest.java | 2 +-
.../DualMirrorWithContainerTest.java | 10 +-
.../isolated/amqp/JMSSaslExternalLDAPTest.java | 2 +-
.../isolated/amqp/SaslKrb5LDAPSecurityTest.java | 2 +-
.../isolated/client/ConnectionDroppedTest.java | 32 +-
.../isolated/web/WebServerComponentTest.java | 6 +-
.../integration/SimpleNotificationService.java | 12 +-
.../tests/integration/String64KLimitTest.java | 8 +-
.../tests/integration/amqp/AMQPPrintDataTest.java | 4 +-
.../integration/amqp/AmqpExpiredMessageTest.java | 6 +-
.../integration/amqp/AmqpIngressTimestampTest.java | 15 +-
.../integration/amqp/AmqpLargeMessageTest.java | 53 +--
.../integration/amqp/AmqpMessageDivertsTest.java | 12 +-
.../amqp/AmqpProtocolHeaderHandlingTest.java | 10 +-
.../amqp/AmqpReferenceDeliveryAnnotationTest.java | 15 +-
.../integration/amqp/AmqpTransactionTest.java | 6 +-
.../integration/amqp/JMSMessageProducerTest.java | 15 +-
.../integration/amqp/JMSSaslExternalTest.java | 2 +-
.../tests/integration/amqp/JMSSaslGssapiTest.java | 4 +-
.../integration/amqp/ParseAppMultiThread.java | 2 +-
.../integration/amqp/QueueAutoCreationTest.java | 8 +-
.../integration/amqp/connect/AMQPBridgeTest.java | 16 +-
.../amqp/connect/AMQPMirrorExpiryQueueTest.java | 4 +-
.../connect/AMQPMirrorOneSideDisconnectedTest.java | 6 +-
.../amqp/connect/AMQPMirrorTemporaryQueueTest.java | 4 +-
.../integration/amqp/connect/AMQPReplicaTest.java | 12 +-
.../amqp/connect/AMQPSyncMirrorTest.java | 18 +-
.../integration/amqp/connect/AckManagerTest.java | 24 +-
.../integration/amqp/connect/BrokerInSyncTest.java | 13 +-
.../integration/amqp/connect/PagedMirrorTest.java | 9 +-
.../amqp/connect/SNFPagedMirrorTest.java | 15 +-
.../integration/amqp/interop/AmqpCoreTest.java | 4 +-
.../AMQPLargeMessageOverCoreBridgeTest.java | 16 +-
.../largemessages/AMQPLargeMessagesTestUtil.java | 3 +-
.../amqp/paging/AmqpMaxReadPagingTest.java | 7 +-
.../integration/amqp/paging/AmqpPagingTest.java | 14 +-
.../artemis/tests/integration/cli/RecoverTest.java | 14 +-
.../integration/client/AddressSettingsTest.java | 12 +-
.../client/AutoCreateJmsDestinationTest.java | 14 +-
.../tests/integration/client/AutoCreateTest.java | 4 +-
.../integration/client/AutoDeleteAddressTest.java | 6 +-
.../integration/client/ConfirmationWindowTest.java | 2 +-
.../integration/client/ConsumerCloseTest.java | 4 +-
.../integration/client/ConsumerFilterTest.java | 6 +-
.../tests/integration/client/ConsumerTest.java | 6 +-
.../integration/client/DeadLetterAddressTest.java | 26 +-
.../integration/client/DeleteAddressTest.java | 4 +-
.../tests/integration/client/DurableQueueTest.java | 16 +-
.../integration/client/ExpiryAddressTest.java | 10 +-
.../integration/client/FullQualifiedQueueTest.java | 4 +-
.../client/InVMNonPersistentMessageBufferTest.java | 10 +-
.../client/IncompatibleVersionTest.java | 4 +-
.../integration/client/IngressTimestampTest.java | 23 +-
.../tests/integration/client/LargeMessageTest.java | 36 +-
.../integration/client/MessageDurabilityTest.java | 20 +-
.../integration/client/MessageExpirationTest.java | 28 +-
.../integration/client/MessagePriorityTest.java | 20 +-
.../integration/client/ProducerCloseTest.java | 2 +-
.../tests/integration/client/ReceiveTest.java | 10 +-
.../tests/integration/client/RequestorTest.java | 24 +-
.../client/RescheduleJDBCDeliveryTest.java | 2 +-
.../client/ScheduledMessageRestartTest.java | 4 +-
.../tests/integration/client/SessionCloseTest.java | 23 +-
.../integration/client/SessionFactoryTest.java | 4 +-
.../client/SimpleSendMultipleQueuesTest.java | 2 +-
.../tests/integration/client/SlowConsumerTest.java | 2 +-
.../integration/client/TemporaryQueueTest.java | 32 +-
.../integration/client/TransientQueueTest.java | 10 +-
.../integration/clientcrash/ClientExitTest.java | 2 +-
.../integration/cluster/bridge/BridgeTest.java | 2 +-
.../crossprotocol/LargeHeadersClusterTest.java | 10 +-
.../ProtocolsMessageLoadBalancingTest.java | 18 +-
.../distribution/ClusterConnectionConfigTest.java | 4 +-
.../cluster/distribution/ClusterTestBase.java | 39 +-
.../distribution/ClusteredMessageCounterTest.java | 6 +-
.../cluster/topology/TopologyClusterTestBase.java | 2 +-
.../consumer/OrphanedConsumerDefenseTest.java | 8 +-
.../discovery/DiscoveryStayAliveTest.java | 4 +-
.../tests/integration/discovery/DiscoveryTest.java | 80 ++--
.../tests/integration/divert/DivertTest.java | 10 +-
.../federation/FederatedQueueConsumerTest.java | 4 +-
.../integration/http/CoreClientOverHttpTest.java | 20 +-
.../jms/ActiveMQConnectionFactoryTest.java | 6 +-
.../integration/jms/bridge/JMSBridgeImplTest.java | 4 +-
.../jms/client/NoLocalSubscriberTest.java | 6 +-
.../jms/cluster/LargeMessageOverBridgeTest.java | 20 +-
.../ConnectionFactorySerializationTest.java | 6 +-
.../jms/consumer/CreateSubscriptionTest.java | 2 +-
.../jms/jms2client/InvalidDestinationTest.java | 2 +-
.../jms/largemessage/JMSLargeMessageTest.java | 19 +-
.../jms/multiprotocol/JMSClientIDTest.java | 8 +-
.../jms/multiprotocol/JMSCorrelationIDTest.java | 4 +-
.../integration/jms/multiprotocol/JMSLVQTest.java | 4 +-
.../jms/multiprotocol/JMSMessageConsumerTest.java | 2 +-
.../multiprotocol/JMSMessagePropertiesTest.java | 2 +-
.../jms/multiprotocol/JMSMessageTypesTest.java | 4 +-
.../JMSMismatchedRoutingTypeTest.java | 10 +-
.../jms/multiprotocol/JMSNonDestructiveTest.java | 2 +-
.../jms/multiprotocol/JMSNotificationTest.java | 6 +-
.../jms/server/config/JMSConfigurationTest.java | 6 +-
.../integration/jms/server/management/JMSUtil.java | 2 +-
.../integration/journal/JournalHashMapTest.java | 2 +-
.../management/AcceptorControlTest.java | 8 +-
.../management/ActiveMQServerControlTest.java | 224 +++++------
.../integration/management/AddressControlTest.java | 106 +++---
.../integration/management/BridgeControlTest.java | 10 +-
.../management/BridgeControlUsingCoreTest.java | 10 +-
.../management/BroadcastGroupControlTest.java | 2 +-
.../management/ClusterConnectionControl2Test.java | 4 +-
.../management/ClusterConnectionControlTest.java | 12 +-
.../integration/management/DivertControlTest.java | 16 +-
.../JGroupsChannelBroadcastGroupControlTest.java | 2 +-
.../JGroupsFileBroadcastGroupControlTest.java | 2 +-
.../management/LargeMessageOverManagementTest.java | 8 +-
.../management/ManagementHelperTest.java | 64 ++--
.../management/ManagementServiceImplTest.java | 18 +-
.../management/ManagementWithPagingServerTest.java | 34 +-
.../integration/management/NotificationTest.java | 46 +--
.../integration/management/QueueControlTest.java | 423 ++++++++++-----------
.../management/SSLSecurityNotificationTest.java | 6 +-
.../management/SecurityNotificationTest.java | 14 +-
.../management/SimpleManagementTest.java | 4 +-
.../mqtt/MQTTDisabledLinkStealingTest.java | 4 +-
.../integration/mqtt/MQTTSecurityManagerTest.java | 10 +-
.../artemis/tests/integration/mqtt/MQTTTest.java | 8 +-
.../tests/integration/mqtt/PahoMQTTTest.java | 6 +-
.../artemis/tests/integration/mqtt5/MQTT5Test.java | 38 +-
.../mqtt5/MQTTRetainMessageManagerTest.java | 2 +-
.../integration/mqtt5/MQTTStateManagerTest.java | 4 +-
.../mqtt5/spec/ControlPacketFormatTests.java | 4 +-
.../mqtt5/spec/EnhancedAuthenticationTests.java | 6 +-
.../mqtt5/spec/MessageDeliveryRetryTests.java | 8 +-
.../mqtt5/spec/MessageReceiptTests.java | 4 +-
.../tests/integration/mqtt5/spec/QoSTests.java | 38 +-
.../mqtt5/spec/controlpackets/ConnAckTests.java | 41 +-
.../mqtt5/spec/controlpackets/ConnectTests.java | 58 +--
.../controlpackets/ConnectTestsWithSecurity.java | 10 +-
.../mqtt5/spec/controlpackets/DisconnectTests.java | 4 +-
.../mqtt5/spec/controlpackets/PingReqTests.java | 4 +-
.../mqtt5/spec/controlpackets/PubAckTests.java | 2 +-
.../mqtt5/spec/controlpackets/PubCompTests.java | 2 +-
.../mqtt5/spec/controlpackets/PubRecTests.java | 2 +-
.../mqtt5/spec/controlpackets/PubRelTests.java | 2 +-
.../mqtt5/spec/controlpackets/PublishTests.java | 64 ++--
.../controlpackets/PublishTestsWithSecurity.java | 4 +-
.../mqtt5/spec/controlpackets/SubAckTests.java | 2 +-
.../mqtt5/spec/controlpackets/SubscribeTests.java | 18 +-
.../controlpackets/SubscribeTestsWithSecurity.java | 6 +-
.../mqtt5/spec/controlpackets/UnsubAckTests.java | 4 +-
.../spec/controlpackets/UnsubscribeTests.java | 8 +-
.../tests/integration/mqtt5/ssl/BasicSslTests.java | 4 +-
.../ssl/CertificateAuthenticationSslTests.java | 4 +-
.../mqtt5/websocket/BasicWebSocketTests.java | 4 +-
.../integration/openwire/BasicOpenWireTest.java | 59 ++-
.../LargeMessageQueueAutoCreationTest.java | 41 +-
.../openwire/OpenWireFlowControlFailTest.java | 11 +-
.../openwire/OpenWireLargeMessageTest.java | 27 +-
.../openwire/OpenWireScheduledDelayTest.java | 10 +-
.../integration/openwire/SecurityOpenWireTest.java | 4 +-
.../integration/openwire/SimpleOpenWireTest.java | 8 +-
.../openwire/interop/CompressedInteropTest.java | 9 +-
.../paging/AnonymousProducerPageTest.java | 7 +-
.../paging/IndividualAckPagingTest.java | 9 +-
.../integration/paging/JournalPagingTest.java | 4 +-
.../paging/MessagesExpiredPagingTest.java | 10 +-
.../persistence/ConnectorStorageTest.java | 6 +-
.../persistence/JMSStorageManagerTest.java | 2 +-
.../persistence/ResizeDuplicateCacheTest.java | 2 +-
.../TransportConfigurationEncodingSupportTest.java | 2 +-
.../persistence/XmlImportExportTest.java | 32 +-
.../plugin/PassthroughMetricsPluginTest.java | 2 +-
.../replication/RepeatStartBackupTest.java | 4 +-
.../replication/ReplicationOrderTest.java | 4 +-
.../tests/integration/retention/ReplayTest.java | 13 +-
.../scheduling/ScheduledMessageTest.java | 6 +-
.../integration/security/FQQNSendSecurityTest.java | 4 +-
.../security/PersistedSecuritySettingTest.java | 4 +-
.../tests/integration/security/SecurityTest.java | 4 +-
.../tests/integration/security/SimpleClient.java | 4 +-
.../server/AddressQueueDeleteDelayTest.java | 24 +-
.../server/AutoCreateDeadLetterResourcesTest.java | 14 +-
.../server/AutoCreateExpiryResourcesTest.java | 14 +-
.../integration/server/ConfigurationTest.java | 4 +-
.../artemis/tests/integration/server/LVQTest.java | 2 +-
.../integration/server/MessageExpirationTest.java | 30 +-
.../tests/integration/server/RingQueueTest.java | 2 +-
.../server/SecureConfigurationTest.java | 16 +-
.../integration/server/TempQueueNamespaceTest.java | 12 +-
.../ssl/CoreClientOverOneWaySSLTest.java | 32 +-
.../ssl/CoreClientOverTwoWaySSLTest.java | 11 +-
.../integration/ssl/DualAuthenticationTest.java | 2 +-
.../artemis/tests/integration/ssl/SslPEMTest.java | 2 +-
.../integration/stomp/StompAuditLoggingTest.java | 4 +-
.../artemis/tests/integration/stomp/StompTest.java | 43 ++-
.../stomp/StompWithLargeMessagesTest.java | 7 +-
.../tests/integration/stomp/v11/StompV11Test.java | 13 +-
.../tests/integration/stomp/v12/StompV12Test.java | 13 +-
.../netty/NettyConnectorWithHTTPUpgradeTest.java | 4 +-
.../jms/tests/MessageWithReadResolveTest.java | 2 +-
.../message/foreign/ForeignBytesMessageTest.java | 2 +-
.../artemis/tests/leak/CoreClientLeakTest.java | 4 +-
.../tests/leak/MessageReferenceLeakTest.java | 4 +-
.../artemis/tests/leak/RedistributorLeakTest.java | 2 +-
.../tests/leak/RefCountMessageLeakTest.java | 4 +-
.../bridgeTransfer/BridgeTransferingTest.java | 11 +-
.../DualMirrorNoContainerTest.java | 11 +-
.../brokerConnection/PagedMirrorSmokeTest.java | 9 +-
.../artemis/tests/smoke/checkTest/CheckTest.java | 2 +-
.../ClusteredLargeMessageTest.java | 20 +-
.../tests/smoke/custometc/CustomETCTest.java | 2 +-
.../smoke/jdbccli/JDBCExportWrongUserTest.java | 4 +-
.../smoke/logging/AuditLoggerResourceTest.java | 2 +-
.../tests/smoke/logging/AuditLoggerTest.java | 8 +-
.../smoke/paging/FloodServerWithAsyncSendTest.java | 11 +-
.../artemis/tests/smoke/retention/ReplayTest.java | 9 +-
.../tests/smoke/upgradeTest/UpgradeTest.java | 2 +-
.../mirror/AccumulatedInPageSoakTest.java | 2 +-
.../mirror/ClusteredMirrorSoakTest.java | 4 +-
.../mirror/DivertSoakMirrorTest.java | 2 +-
.../tests/soak/client/LargeMessageSoakTest.java | 11 +-
.../soak/clientFailure/ClientFailureSoakTest.java | 11 +-
.../clientFailure/ClientFailureSoakTestClient.java | 2 +-
.../ClusterNotificationsContinuityTest.java | 2 +-
.../ClusteredLargeMessageInterruptTest.java | 11 +-
.../soak/interruptlm/LargeMessageFrozenTest.java | 28 +-
.../interruptlm/LargeMessageInterruptTest.java | 11 +-
.../artemis/tests/soak/owleak/OWLeakTest.java | 8 +-
.../tests/soak/paging/FlowControlPagingTest.java | 11 +-
.../tests/soak/paging/HorizontalPagingTest.java | 11 +-
.../tests/soak/paging/M_and_M_FactoryTest.java | 10 +-
.../tests/soak/paging/MegaCleanerPagingTest.java | 10 +-
.../tests/soak/paging/SubscriptionPagingTest.java | 11 +-
.../tests/soak/paging/ValidateExportSpeedTest.java | 7 +-
.../soak/replicaTxCheck/ReplicaTXCheckTest.java | 18 +-
.../replicationflow/SoakReplicatedPagingTest.java | 10 +-
.../soak/retention/LargeMessageRetentionTest.java | 9 +-
.../timing/jms/bridge/impl/JMSBridgeImplTest.java | 4 +-
.../artemis/tests/unit/AllClassesTest.java | 2 +-
.../core/client/impl/LargeMessageBufferTest.java | 8 +-
.../unit/core/message/impl/MessageImplTest.java | 6 +-
.../unit/core/remoting/ActiveMQBufferTestBase.java | 6 +-
.../remoting/impl/netty/NettyAcceptorTest.java | 12 +-
.../cluster/impl/RemoteQueueBindImplTest.java | 16 +-
.../tests/unit/jms/ActiveMQDestinationTest.java | 10 +-
.../unit/jms/client/ActiveMQMapMessageTest.java | 6 +-
.../unit/jms/client/ActiveMQStreamMessageTest.java | 8 +-
.../tests/unit/jms/jndi/ObjectFactoryTest.java | 10 +-
.../tests/unit/logging/AssertionLoggerTest.java | 2 +-
.../unit/ra/ActiveMQResourceAdapterConfigTest.java | 2 +-
.../DestinationObjectFactoryTest.java | 2 +-
.../artemis/tests/unit/util/LinkedListTest.java | 2 +-
531 files changed, 3184 insertions(+), 4504 deletions(-)
delete mode 100644
artemis-cli/src/test/java/org/apache/activemq/cli/test/StringGenerator.java
delete mode 100644
artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/RunnableCallback.java
delete mode 100644
tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/tests/util/RandomUtil.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
