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 c2d69479b8 ARTEMIS-5263 Remove unused Docker directive
add a4cedbcb04 ARTEMIS-5267 use containsKey where possible
add 89e23c2fa0 ARTEMIS-5268 avoid EMPTY_ properties in Collections
add f504b5d256 ARTEMIS-5269 eliminate redundant toString() invocations
add d8db09e7ee ARTEMIS-5270 eliminate redundant casts
add a40b0a5735 ARTEMIS-5272 eliminate unused private fields
add fecbd73e12 ARTEMIS-5273 use collection interfaces where possible
add 1a7da3a33e ARTEMIS-5274 use lambdas where possible
add b49041ac7d ARTEMIS-5275 use line separator method instead of property
add 134f1a90fe ARTEMIS-5276 use text blocks where possible
add 9af357bae0 ARTEMIS-5278 use pattern matching for instanceof
add 0aa9c2d6ea ARTEMIS-5271 eliminate unused variables
add 29e800f76a NO-JIRA fix testSimpleCursorIteratorLargeMessage
add d54c771b2c ARTEMIS-5281 use isEmpty() where possible
No new revisions were added by this update.
Summary of changes:
.../org/apache/activemq/artemis/boot/Artemis.java | 8 +-
.../DefaultArtemisClientConfigurationImpl.java | 2 +-
.../org/apache/activemq/artemis/cli/Artemis.java | 7 +-
.../artemis/cli/commands/Configurable.java | 2 +-
.../activemq/artemis/cli/commands/Create.java | 58 +-
.../activemq/artemis/cli/commands/HelpAction.java | 4 +-
.../artemis/cli/commands/InputAbstract.java | 6 +-
.../artemis/cli/commands/InstallAbstract.java | 5 +-
.../activemq/artemis/cli/commands/Upgrade.java | 5 +-
.../activation/ActivationSequenceList.java | 6 +-
.../commands/activation/ActivationSequenceSet.java | 6 +-
.../artemis/cli/commands/check/CheckAbstract.java | 4 +-
.../cli/commands/check/ClusterNodeVerifier.java | 3 +-
.../artemis/cli/commands/check/NodeCheck.java | 5 +-
.../artemis/cli/commands/check/QueueCheck.java | 5 +-
.../artemis/cli/commands/helper/HelperCreate.java | 4 +-
.../cli/commands/messages/ConsumerThread.java | 30 +-
.../cli/commands/messages/ProducerThread.java | 4 +-
.../artemis/cli/commands/messages/Transfer.java | 4 +-
.../artemis/cli/commands/queue/StatQueue.java | 17 +-
.../artemis/cli/commands/tools/PrintData.java | 2 +-
.../cli/commands/tools/RecoverMessages.java | 5 +-
.../cli/commands/tools/journal/DecodeJournal.java | 4 +-
.../cli/commands/tools/xml/XMLMessageExporter.java | 8 +-
.../cli/commands/tools/xml/XMLMessageImporter.java | 12 +-
.../cli/commands/tools/xml/XmlDataExporter.java | 24 +-
.../commands/tools/xml/XmlDataExporterUtil.java | 4 +-
.../cli/commands/tools/xml/XmlDataImporter.java | 2 +-
.../artemis/cli/commands/util/SyncCalculation.java | 1 -
.../activemq/artemis/integration/FileBroker.java | 11 +-
.../apache/activemq/artemis/util/ServerUtil.java | 3 +-
.../activemq/artemis/util/JVMArgumentTest.java | 5 +-
.../org/apache/activemq/cli/test/ArtemisTest.java | 12 +-
.../activemq/cli/test/MessageSerializerTest.java | 12 +-
.../artemis/api/core/ActiveMQExceptionType.java | 2 +-
.../artemis/api/core/ParameterisedAddress.java | 2 +-
.../artemis/api/core/QueueConfiguration.java | 2 +-
.../activemq/artemis/api/core/SimpleString.java | 6 +-
.../activemq/artemis/json/impl/JsonArrayImpl.java | 4 +-
.../activemq/artemis/json/impl/JsonValueImpl.java | 4 +-
.../apache/activemq/artemis/logs/AuditLogger.java | 39 +-
.../artemis/utils/DefaultSensitiveStringCodec.java | 2 +-
.../org/apache/activemq/artemis/utils/Env.java | 2 +-
.../activemq/artemis/utils/InetAddresses.java | 8 +-
.../apache/activemq/artemis/utils/ListUtil.java | 2 +-
.../activemq/artemis/utils/SpawnedVMSupport.java | 9 +-
.../apache/activemq/artemis/utils/TableOut.java | 13 +-
.../activemq/artemis/utils/UUIDGenerator.java | 2 +-
.../activemq/artemis/utils/bean/MetaBean.java | 9 +-
.../artemis/utils/collections/LinkedListImpl.java | 3 +-
.../artemis/utils/collections/LongHashSet.java | 7 +-
.../artemis/utils/collections/NoOpMap.java | 2 +-
.../utils/collections/PriorityCollection.java | 5 +-
.../artemis/utils/collections/TypedProperties.java | 150 ++--
.../utils/critical/CriticalAnalyzerImpl.java | 6 +-
.../artemis/utils/runnables/AtomicRunnable.java | 4 +-
.../artemis/utils/runnables/RunnableList.java | 3 +-
.../activemq/artemis/utils/uri/BeanSupport.java | 2 +-
.../activemq/artemis/utils/uri/URIFactory.java | 2 +-
.../activemq/artemis/utils/uri/URISupport.java | 16 +-
.../artemis/api/core/ParameterisedAddressTest.java | 6 +-
.../activemq/artemis/utils/ByteUtilTest.java | 3 +-
.../activemq/artemis/utils/TableOutTest.java | 6 +-
.../utils/TypedPropertiesConcurrencyTest.java | 2 -
.../artemis/utils/TypedPropertiesTest.java | 4 +-
.../collections/ConcurrentLongHashMapTest.java | 6 +-
.../utils/collections/MultiIteratorTest.java | 9 +-
.../collections/MultiResettableIteratorTest.java | 15 +-
.../utils/collections/UpdatableIteratorTest.java | 7 +-
.../artemis/utils/runnables/RunnableListTest.java | 8 +-
.../api/config/ActiveMQDefaultConfiguration.java | 6 -
.../apache/activemq/artemis/api/core/JsonUtil.java | 157 ++--
.../apache/activemq/artemis/api/core/Message.java | 4 +-
.../activemq/artemis/api/core/RefCountMessage.java | 10 +-
.../artemis/api/core/TransportConfiguration.java | 16 +-
.../api/core/management/ObjectNameBuilder.java | 2 +-
.../artemis/core/client/impl/AddressQueryImpl.java | 2 +-
.../core/client/impl/ClientSessionFactoryImpl.java | 18 +-
.../core/client/impl/ClientSessionImpl.java | 10 +-
.../core/client/impl/ServerLocatorImpl.java | 17 +-
.../artemis/core/client/impl/Topology.java | 17 +-
.../core/client/impl/TopologyMemberImpl.java | 2 -
.../core/config/TransformerConfiguration.java | 4 +-
.../artemis/core/message/impl/CoreMessage.java | 8 +-
.../message/openmbean/MessageOpenTypeFactory.java | 2 +-
.../core/impl/ActiveMQClientProtocolManager.java | 20 +-
.../impl/ActiveMQClientProtocolManagerFactory.java | 2 -
.../protocol/core/impl/ActiveMQSessionContext.java | 46 +-
.../artemis/core/remoting/CertificateUtil.java | 20 +-
.../remoting/impl/TransportConfigurationUtil.java | 10 +-
.../remoting/impl/netty/CheckDependencies.java | 5 -
.../core/remoting/impl/netty/NettyConnector.java | 11 +-
.../remoting/impl/netty/SharedEventLoopGroup.java | 7 +-
.../artemis/core/remoting/impl/ssl/SSLSupport.java | 4 +-
.../activemq/artemis/reader/BytesMessageUtil.java | 40 +-
.../activemq/artemis/reader/MessageUtil.java | 14 +-
.../artemis/spi/core/remoting/SessionContext.java | 4 +-
.../connector/TCPTransportConfigurationSchema.java | 4 +-
.../serverLocator/JGroupsServerLocatorSchema.java | 4 +-
.../serverLocator/TCPServerLocatorSchema.java | 4 +-
.../artemis/utils/ConfigurationHelper.java | 16 +-
.../apache/activemq/artemis/utils/JNDIUtil.java | 4 +-
.../utils/ObjectInputStreamWithClassLoader.java | 18 +-
.../apache/activemq/artemis/utils/PrefixUtil.java | 2 +-
.../apache/activemq/artemis/utils/StringUtil.java | 2 +-
.../org/apache/activemq/artemis/utils/XMLUtil.java | 2 +-
.../activemq/artemis/api/core/JsonUtilTest.java | 1 -
.../api/core/TransportConfigurationTest.java | 6 +-
.../core/management/AddressSettingsInfoTest.java | 119 +--
.../activemq/artemis/util/CompressionUtilTest.java | 7 +-
.../jdbc/store/file/JDBCSequentialFile.java | 5 +-
.../store/journal/JDBCJournalLoaderCallback.java | 2 +-
.../jdbc/store/sql/PropertySQLProvider.java | 4 +-
.../journal/JDBCJournalLoaderCallbackTest.java | 5 +-
.../artemis/jms/client/ActiveMQConnection.java | 5 +-
.../jms/client/ActiveMQConnectionFactory.java | 19 +-
.../artemis/jms/client/ActiveMQJMSProducer.java | 43 +-
.../artemis/jms/client/ActiveMQMapMessage.java | 6 +-
.../artemis/jms/client/ActiveMQMessage.java | 8 +-
.../jms/client/ActiveMQMessageProducer.java | 44 +-
.../artemis/jms/client/ActiveMQSession.java | 12 +-
.../artemis/jms/client/ActiveMQStreamMessage.java | 40 +-
.../artemis/jndi/JNDIReferenceFactory.java | 3 +-
.../activemq/artemis/jndi/ReadOnlyContext.java | 32 +-
.../apache/activemq/artemis/uri/JGroupsSchema.java | 4 +-
.../org/apache/activemq/artemis/jndi/JndiTest.java | 6 +-
.../artemis/uri/ConnectionFactoryURITest.java | 4 +-
.../artemis/jms/bridge/impl/JMSBridgeImpl.java | 17 +-
.../jms/persistence/config/PersistedBindings.java | 2 +-
.../impl/journal/JMSJournalStorageManagerImpl.java | 6 +-
.../server/config/impl/FileJMSConfiguration.java | 9 +-
.../jms/server/impl/JMSServerManagerImpl.java | 21 +-
.../core/io/AbstractSequentialFileFactory.java | 2 +-
.../core/io/aio/AIOSequentialFileFactory.java | 2 +-
.../core/journal/collections/JournalHashMap.java | 3 +-
.../collections/JournalHashMapProvider.java | 2 +-
.../journal/impl/AbstractJournalUpdateTask.java | 2 +-
.../core/journal/impl/JournalFilesRepository.java | 11 +-
.../artemis/core/journal/impl/JournalImpl.java | 40 +-
.../artemis/core/io/aio/CallbackOrderTest.java | 3 +-
.../junit/AbstractActiveMQClientDelegate.java | 2 +-
.../artemis/junit/EmbeddedActiveMQDelegate.java | 2 +-
.../artemis/junit/EmbeddedJMSDelegate.java | 4 +-
.../zookeeper/CuratorDistributedLock.java | 3 +-
.../zookeeper/CuratorDistributedLockManager.java | 3 +-
.../artemis/lockmanager/DistributedLockTest.java | 3 +-
.../CuratorDistributedLockManagerTest.java | 2 +-
.../processor/LogAnnotationProcessor.java | 14 +-
.../artemis/maven/ArtemisCreatePlugin.java | 12 +-
.../artemis/maven/ArtemisDependencyDocPlugin.java | 11 +-
.../activemq/artemis/maven/ArtemisStopPlugin.java | 3 -
.../artemis/maven/ArtemisUpgradePlugin.java | 8 +-
.../artemis/protocol/amqp/broker/AMQPMessage.java | 33 +-
.../amqp/broker/AMQPMessageSymbolSearch.java | 7 +-
.../protocol/amqp/broker/AMQPSessionCallback.java | 4 +-
.../protocol/amqp/broker/AMQPStandardMessage.java | 4 +-
.../amqp/broker/ProtonProtocolManager.java | 11 +-
.../amqp/broker/ProtonProtocolManagerFactory.java | 2 +-
.../amqp/connect/AMQPBrokerConnection.java | 29 +-
.../amqp/connect/AMQPBrokerConnectionManager.java | 5 +-
.../amqp/connect/federation/AMQPFederation.java | 8 +-
.../federation/AMQPFederationAddressConsumer.java | 4 +-
.../AMQPFederationAddressPolicyManager.java | 10 +-
.../AMQPFederationAddressSenderController.java | 2 +-
.../AMQPFederationCommandDispatcher.java | 2 +-
.../federation/AMQPFederationConfiguration.java | 74 +-
.../connect/federation/AMQPFederationConsumer.java | 8 +-
.../AMQPFederationConsumerConfiguration.java | 74 +-
.../federation/AMQPFederationEventDispatcher.java | 8 +-
.../federation/AMQPFederationPolicySupport.java | 16 +-
.../AMQPFederationQueuePolicyManager.java | 3 +-
.../connect/federation/AMQPFederationSource.java | 6 +-
.../connect/federation/AMQPFederationTarget.java | 4 +-
.../mirror/AMQPMirrorControllerAggregation.java | 2 +-
.../connect/mirror/AMQPMirrorControllerSource.java | 8 +-
.../connect/mirror/AMQPMirrorControllerTarget.java | 3 +-
.../protocol/amqp/connect/mirror/AckManager.java | 10 +-
.../amqp/connect/mirror/AckManagerProvider.java | 3 +-
.../amqp/connect/mirror/ReferenceNodeStore.java | 3 +-
.../amqp/converter/AMQPMessageIdHelper.java | 14 +-
.../amqp/converter/AMQPMessageSupport.java | 5 +-
.../protocol/amqp/converter/AmqpCoreConverter.java | 53 +-
.../protocol/amqp/converter/CoreAmqpConverter.java | 18 +-
.../coreWrapper/CoreMapMessageWrapper.java | 24 +-
.../converter/coreWrapper/CoreMessageWrapper.java | 4 +-
.../coreWrapper/CoreStreamMessageWrapper.java | 43 +-
.../amqp/exceptions/ActiveMQAMQPException.java | 2 -
.../FederationReceiveFromAddressPolicy.java | 6 +-
.../FederationReceiveFromQueuePolicy.java | 6 +-
.../amqp/logger/ActiveMQAMQPProtocolLogger.java | 27 +-
.../amqp/proton/AMQPConnectionContext.java | 20 +-
.../protocol/amqp/proton/AMQPSessionContext.java | 14 +-
.../amqp/proton/AMQPTunneledCoreMessageWriter.java | 2 +-
.../amqp/proton/DefaultSenderController.java | 2 +-
.../amqp/proton/ProtonServerReceiverContext.java | 2 +-
.../amqp/proton/ProtonServerSenderContext.java | 9 +-
.../transaction/ProtonTransactionHandler.java | 7 +-
.../ProtonTransactionRefsOperation.java | 2 +-
.../protocol/amqp/sasl/GSSAPIServerSASL.java | 3 +-
.../amqp/sasl/GSSAPIServerSASLFactory.java | 4 +-
.../protocol/amqp/sasl/scram/SCRAMClientSASL.java | 2 +-
.../amqp/sasl/scram/SCRAMServerSASLFactory.java | 20 +-
.../protocol/amqp/broker/AMQPMessageTest.java | 9 +-
.../hornetq/HQPropertiesConversionInterceptor.java | 2 +-
.../core/protocol/mqtt/MQTTPublishManager.java | 4 +-
.../core/protocol/mqtt/MQTTSessionState.java | 4 +-
.../core/protocol/mqtt/MQTTStateManager.java | 4 +-
.../artemis/core/protocol/mqtt/MQTTUtil.java | 12 +-
.../core/protocol/openwire/OpenWireConnection.java | 10 +-
.../openwire/OpenWireMessageConverter.java | 59 +-
.../protocol/openwire/OpenWireProtocolManager.java | 13 +-
.../ra/ActiveMQRAConnectionRequestInfo.java | 13 +-
.../artemis/ra/ActiveMQRAManagedConnection.java | 7 +-
.../ra/ActiveMQRAManagedConnectionFactory.java | 11 +-
.../activemq/artemis/ra/ActiveMQRAMessage.java | 4 +-
.../artemis/ra/ActiveMQRAMessageConsumer.java | 20 +-
.../activemq/artemis/ra/ActiveMQRAProperties.java | 2 +-
.../artemis/ra/ActiveMQRASessionFactoryImpl.java | 8 +-
.../activemq/artemis/ra/ActiveMQRaUtils.java | 2 +-
.../artemis/ra/ActiveMQResourceAdapter.java | 6 +-
.../artemis/ra/inflow/ActiveMQActivation.java | 20 +-
.../artemis/ra/inflow/ActiveMQActivationSpec.java | 2 +-
.../inflow/ActiveMQActivationValidationUtils.java | 8 +-
.../artemis/ra/inflow/ActiveMQMessageHandler.java | 2 +-
.../selector/filter/ArithmeticExpression.java | 19 +-
.../selector/filter/ComparisonExpression.java | 16 +-
.../selector/filter/ConstantExpression.java | 8 +-
.../artemis/selector/filter/LogicExpression.java | 10 +-
.../artemis/selector/filter/UnaryExpression.java | 4 +-
.../activemq/artemis/selector/MockMessage.java | 3 +-
.../activemq/artemis/selector/SelectorTest.java | 27 -
.../apache/activemq/artemis/osgi/OsgiBroker.java | 8 +-
.../artemis/core/config/FileDeploymentManager.java | 2 +-
.../core/config/impl/ConfigurationImpl.java | 105 ++-
.../core/config/impl/LegacyJMSConfiguration.java | 4 -
.../artemis/core/config/impl/Validators.java | 2 +-
.../deployers/impl/FileConfigurationParser.java | 42 +-
.../artemis/core/filter/impl/FilterImpl.java | 2 +-
.../management/impl/ActiveMQServerControlImpl.java | 41 +-
.../core/management/impl/AddressControlImpl.java | 4 +-
.../core/management/impl/DivertControlImpl.java | 8 +-
.../core/management/impl/MBeanInfoHelper.java | 5 +-
.../core/management/impl/QueueControlImpl.java | 10 +-
.../management/impl/view/ActiveMQAbstractView.java | 6 +-
.../view/predicate/AddressFilterPredicate.java | 2 +-
.../view/predicate/ConnectionFilterPredicate.java | 2 +-
.../view/predicate/ConsumerFilterPredicate.java | 2 +-
.../view/predicate/ProducerFilterPredicate.java | 2 +-
.../impl/view/predicate/QueueFilterPredicate.java | 2 +-
.../view/predicate/SessionFilterPredicate.java | 2 +-
.../paging/cursor/impl/PageCursorProviderImpl.java | 42 +-
.../artemis/core/paging/impl/PageReadWriter.java | 1 -
.../artemis/core/paging/impl/PageSyncTimer.java | 2 -
.../core/paging/impl/PageTransactionInfoImpl.java | 2 +-
.../artemis/core/paging/impl/PagedMessageImpl.java | 4 +-
.../core/paging/impl/PagingManagerImpl.java | 5 +-
.../paging/impl/PagingStoreFactoryDatabase.java | 2 +-
.../core/paging/impl/PagingStoreFactoryNIO.java | 2 +-
.../artemis/core/paging/impl/PagingStoreImpl.java | 4 +-
.../journal/AbstractJournalStorageManager.java | 6 +-
.../persistence/impl/journal/DescribeJournal.java | 11 +-
.../impl/journal/JournalStorageManager.java | 6 +-
.../core/persistence/impl/journal/LargeBody.java | 4 +-
.../impl/journal/LargeServerMessageImpl.java | 4 +-
.../artemis/core/postoffice/impl/AddressImpl.java | 2 +-
.../core/postoffice/impl/AddressPartNode.java | 4 +-
.../artemis/core/postoffice/impl/BindingsImpl.java | 4 +-
.../artemis/core/postoffice/impl/ByteArray.java | 5 +-
.../core/postoffice/impl/CopyOnWriteBindings.java | 3 +-
.../postoffice/impl/InMemoryDuplicateIDCache.java | 2 +-
.../impl/PersistentDuplicateIDCache.java | 2 +-
.../core/postoffice/impl/PostOfficeImpl.java | 11 +-
.../core/postoffice/impl/SimpleAddressManager.java | 15 +-
.../artemis/core/protocol/ProtocolHandler.java | 5 +-
.../artemis/core/protocol/ServerPacketDecoder.java | 8 +-
.../protocol/core/ServerSessionPacketHandler.java | 12 +-
.../protocol/core/impl/ActiveMQPacketHandler.java | 4 +-
.../protocol/core/impl/CoreProtocolManager.java | 2 +-
.../BackupReplicationStartFailedMessage.java | 2 +-
.../core/remoting/impl/invm/InVMConnector.java | 30 +-
.../remoting/impl/netty/HttpAcceptorHandler.java | 4 +-
.../remoting/server/impl/RemotingServiceImpl.java | 6 +-
.../core/replication/ReplicationEndpoint.java | 10 +-
.../core/replication/ReplicationManager.java | 9 +-
.../core/security/impl/SecurityStoreImpl.java | 38 +-
.../activemq/artemis/core/server/JournalType.java | 2 +-
.../activemq/artemis/core/server/QueueConfig.java | 2 +-
.../ActiveMQServerSideProtocolManagerFactory.java | 2 -
.../core/server/cluster/ClusterManager.java | 2 +-
.../core/server/cluster/ha/ReplicatedPolicy.java | 4 +-
.../core/server/cluster/impl/BridgeImpl.java | 4 +-
.../cluster/impl/ClusterConnectionBridge.java | 15 +-
.../artemis/core/server/cluster/quorum/Vote.java | 2 +-
.../core/server/embedded/EmbeddedActiveMQ.java | 2 +-
.../artemis/core/server/federation/Federation.java | 2 -
.../server/federation/FederationDownstream.java | 2 +-
.../core/server/federation/FederationUpstream.java | 11 +-
.../federation/address/FederatedAddress.java | 20 +-
.../server/group/impl/LocalGroupingHandler.java | 6 +-
.../server/impl/AbstractProtocolReference.java | 3 +-
.../core/server/impl/ActiveMQServerImpl.java | 53 +-
.../artemis/core/server/impl/AddressInfo.java | 12 +-
.../server/impl/AnyNodeLocatorForReplication.java | 2 +-
.../server/impl/AnyNodeLocatorForScaleDown.java | 2 +-
.../server/impl/BackupRecoveryJournalLoader.java | 2 +-
.../core/server/impl/ColocatedActivation.java | 2 +-
.../core/server/impl/MessageReferenceImpl.java | 5 +-
.../impl/NamedNodeIdLocatorForReplication.java | 7 +-
.../impl/NamedNodeLocatorForReplication.java | 7 +-
.../server/impl/NamedNodeLocatorForScaleDown.java | 2 +-
.../artemis/core/server/impl/QueueFactoryImpl.java | 2 +-
.../artemis/core/server/impl/QueueImpl.java | 31 +-
.../artemis/core/server/impl/ScaleDownHandler.java | 16 +-
.../server/impl/ScheduledDeliveryHandlerImpl.java | 2 +-
.../core/server/impl/ServerSessionImpl.java | 16 +-
.../artemis/core/server/impl/ServerStatus.java | 7 +-
.../management/ArtemisMBeanServerBuilder.java | 4 +-
.../management/ArtemisRbacInvocationHandler.java | 14 +-
.../core/server/management/BasicAuthenticator.java | 4 +-
.../server/management/ConnectorServerFactory.java | 2 +-
.../server/management/JMXAccessControlList.java | 10 +-
.../core/server/management/JaasAuthenticator.java | 12 +-
.../core/server/management/MBeanServerFactory.java | 2 +-
.../server/management/ManagementConnector.java | 4 +-
.../management/impl/HawtioSecurityControlImpl.java | 2 +-
.../management/impl/ManagementServiceImpl.java | 20 +-
.../impl/ConnectionPeriodicExpiryPlugin.java | 3 +-
.../protocol/websocket/WebSocketFrameEncoder.java | 4 +-
.../protocol/websocket/WebSocketServerHandler.java | 11 +-
.../artemis/core/server/replay/ReplayManager.java | 24 +-
.../artemis/core/server/routing/KeyType.java | 2 +-
.../routing/policies/ConsistentHashPolicy.java | 4 +-
.../routing/policies/FirstElementPolicy.java | 2 +-
.../routing/policies/LeastConnectionsPolicy.java | 2 +-
.../server/routing/policies/RoundRobinPolicy.java | 2 +-
.../core/server/transformer/ServerMessageImpl.java | 2 -
.../impl/HierarchicalObjectRepository.java | 4 +-
.../core/transaction/impl/TransactionImpl.java | 2 -
.../protocol/AbstractProtocolManagerFactory.java | 2 +-
.../spi/core/protocol/EmbedMessageUtil.java | 8 +-
.../spi/core/protocol/MessagePersister.java | 4 +-
.../security/ActiveMQBasicSecurityManager.java | 4 +-
.../core/security/ActiveMQJAASSecurityManager.java | 6 +-
.../security/jaas/HttpServerAuthenticator.java | 18 +-
.../core/security/jaas/JaasCallbackHandler.java | 19 +-
.../spi/core/security/jaas/LDAPLoginModule.java | 6 +-
.../spi/core/security/jaas/PropertiesLoader.java | 2 +-
.../jaas/PropertiesLoginModuleConfigurator.java | 43 +-
.../core/security/jaas/ReloadableProperties.java | 6 +-
.../spi/core/security/scram/ScramUtils.java | 2 +-
.../spi/core/security/scram/StringPrep.java | 7 +-
.../artemis/utils/SecurityManagerUtil.java | 2 +-
.../artemis/utils/XMLConfigurationUtil.java | 2 +-
.../core/config/impl/ConfigurationImplTest.java | 23 +-
.../config/impl/FileConfigurationParserTest.java | 525 ++++++++-----
.../impl/WrongRoleFileConfigurationParserTest.java | 78 +-
.../artemis/core/list/PriorityLinkedListTest.java | 32 +-
.../management/impl/AcceptorControlImplTest.java | 4 +-
.../impl/journal/OperationContextUnitTest.java | 9 +-
.../security/jaas/CertificateLoginModuleTest.java | 4 +-
.../jaas/LDAPLoginModuleMaskPasswordTest.java | 40 +-
.../security/jaas/LDAPModuleRoleExpansionTest.java | 18 +-
.../PropertiesLoginModuleRaceConditionTest.java | 2 +-
.../security/jaas/PropertiesLoginModuleTest.java | 8 +-
.../jaas/TextFileCertificateLoginModuleTest.java | 18 +-
.../server/group/impl/ClusteredResetMockTest.java | 2 +-
.../server/impl/ScheduledDeliveryHandlerTest.java | 2 +-
.../core/server/impl/jdbc/JdbcNodeManagerTest.java | 5 -
.../policies/ConsistentHashModuloPolicyTest.java | 7 +-
.../routing/policies/ConsistentHashPolicyTest.java | 3 +-
.../routing/policies/FirstElementPolicyTest.java | 3 +-
.../policies/LeastConnectionsPolicyTest.java | 3 +-
.../server/routing/policies/PolicyTestBase.java | 3 +-
.../routing/policies/RoundRobinPolicyTest.java | 2 +-
.../artemis/core/settings/RepositoryTest.java | 17 +-
.../core/security/jaas/LDAPLoginModuleTest.java | 57 +-
.../core/security/jaas/PropertiesLoaderTest.java | 3 +-
.../jaas/kubernetes/TokenCallbackHandler.java | 4 +-
.../client/KubernetesClientImplTest.java | 10 +-
.../artemis/tests/util/ServerTestBase.java | 4 +-
.../xa/recovery/ActiveMQXAResourceRecovery.java | 6 +-
.../xa/recovery/ActiveMQXAResourceWrapper.java | 4 +-
.../tests/extensions/OpenFilesCheckExtension.java | 6 +-
.../tests/extensions/ThreadLeakCheckDelegate.java | 3 +-
.../parameterized/ParameterizedTestExtension.java | 10 +-
.../artemis/tests/util/ArtemisTestCase.java | 2 +-
.../artemis/component/WebServerComponent.java | 4 +-
.../activemq/cli/test/WebServerComponentTest.java | 6 +-
.../org/apache/activemq/broker/BrokerService.java | 2 +-
.../artemiswrapper/OpenwireArtemisBaseTest.java | 6 +-
.../transport/tcp/TcpTransportFactory.java | 2 +-
.../activemq/ActiveMQXAConnectionFactoryTest.java | 3 +-
.../apache/activemq/CombinationTestSupport.java | 14 +-
.../java/org/apache/activemq/JMSMessageTest.java | 3 +-
.../apache/activemq/JmsQueueTransactionTest.java | 3 +-
.../apache/activemq/JmsTempDestinationTest.java | 4 +-
.../apache/activemq/JmsTransactionTestSupport.java | 12 +-
.../apache/activemq/broker/BrokerTestSupport.java | 3 +-
.../activemq/openwire/DataFileGenerator.java | 9 +-
.../java/org/apache/activemq/test/TestSupport.java | 2 -
.../transport/TransportBrokerTestSupport.java | 3 +-
.../transport/failover/FailoverPriorityTest.java | 2 +-
.../transport/failover/FailoverUpdateURIsTest.java | 2 +-
.../failover/TwoBrokerFailoverClusterTest.java | 2 +-
.../stomp/util/AbstractStompClientConnection.java | 2 +-
.../core/journal/impl/JournalImplTestBase.java | 10 +-
.../unit/core/server/impl/fakes/FakeFilter.java | 4 +-
.../artemis/tests/unit/util/InVMContext.java | 7 +-
.../artemis/tests/unit/util/InVMNamingContext.java | 7 +-
.../artemis/tests/util/ActiveMQTestBase.java | 32 +-
.../activemq/artemis/tests/util/TcpProxy.java | 4 +-
.../transport/amqp/client/AmqpConnection.java | 15 +-
.../transport/amqp/client/AmqpMessage.java | 7 +-
.../transport/amqp/client/AmqpReceiver.java | 2 +-
.../activemq/transport/amqp/client/AmqpSender.java | 12 +-
.../amqp/client/AmqpTransactionCoordinator.java | 6 +-
.../amqp/client/sasl/CramMD5Mechanism.java | 2 +-
.../transport/amqp/client/sasl/PlainMechanism.java | 2 +-
.../amqp/client/util/IOExceptionSupport.java | 6 +-
.../transport/amqp/client/util/PropertyUtil.java | 8 +-
.../amqp/client/util/TypeConversionSupport.java | 3 +-
.../amqp/client/util/UnmodifiableProxy.java | 3 +-
.../transport/netty/NettyTransportSupport.java | 4 +-
.../activemq/transport/netty/NettyWSTransport.java | 12 +-
.../main/resources/addresspause/afterstop.groovy | 3 -
.../resources/exportimport/artemisServer.groovy | 2 -
.../src/main/resources/hqsoak/artemisServer.groovy | 2 -
.../prefixSendAckTest/artemisServer.groovy | 2 -
.../src/main/resources/queuepause/afterstop.groovy | 3 -
.../main/resources/servers/artemisServer.groovy | 2 -
.../main/resources/servers/hornetqServer.groovy | 3 -
.../tests/compatibility/HQLargeMeshTest.java | 1 -
.../artemis/tests/compatibility/ReplyToTest.java | 2 +-
.../tests/compatibility/base/ClasspathBase.java | 13 +-
.../tests/compatibility/base/VersionedBase.java | 8 +-
.../artemis/tests/db/common/DBTestBase.java | 6 -
.../activemq/artemis/tests/db/common/Database.java | 4 +-
.../tests/db/common/ParameterDBTestBase.java | 4 +-
.../artemis/tests/db/paging/GlobalPagingTest.java | 9 +-
.../tests/db/paging/NetworkTimeoutCheckTest.java | 9 +-
.../artemis/tests/db/paging/PagingTest.java | 21 +-
.../artemis/tests/e2e/common/ContainerService.java | 4 +-
.../isolated/amqp/SaslKrb5LDAPSecurityTest.java | 10 +-
.../isolated/client/ConnectionDroppedTest.java | 1 -
.../isolated/security/LDAPSecurityTest.java | 2 +-
...egacyLDAPSecuritySettingPluginListenerTest.java | 3 +-
.../LegacyLDAPSecuritySettingPluginTest.java | 5 +-
.../LegacyLDAPSecuritySettingPluginTest2.java | 3 +-
.../isolated/web/WebServerComponentTest.java | 6 +-
.../integration/addressing/SendDLQNoRouteTest.java | 2 -
.../integration/amqp/AmqpClientTestSupport.java | 2 +-
...leReceiverReconnectWithMulticastPrefixTest.java | 6 +-
.../integration/amqp/AmqpExpiredMessageTest.java | 3 +-
.../amqp/AmqpInboundConnectionTest.java | 2 -
.../integration/amqp/AmqpLargeMessageTest.java | 16 +-
.../tests/integration/amqp/AmqpManagementTest.java | 6 +-
.../integration/amqp/AmqpPipelinedConnectTest.java | 7 +-
.../amqp/AmqpReceiverWithFiltersTest.java | 3 +-
.../tests/integration/amqp/AmqpSecurityTest.java | 6 +-
.../amqp/AmqpSenderRoutingTypeTest.java | 2 +-
.../tests/integration/amqp/AmqpTestSupport.java | 4 +-
.../integration/amqp/AmqpTransactionTest.java | 5 +-
.../AutoCreateWithDefaultRoutingTypesTest.java | 2 +-
.../amqp/DLQAfterExpiredMessageTest.java | 2 +-
.../tests/integration/amqp/JMSSaslGssapiTest.java | 2 +-
.../tests/integration/amqp/JMXManagementTest.java | 4 +-
.../integration/amqp/ParseAppMultiThread.java | 3 +-
.../integration/amqp/QueueAutoCreationTest.java | 2 +-
.../tests/integration/amqp/TopicDurableTests.java | 8 +-
.../integration/amqp/connect/AMQPBridgeTest.java | 8 +-
.../connect/AMQPFederationAddressPolicyTest.java | 12 +-
.../AMQPFederationConfigurationReloadTest.java | 4 +-
.../amqp/connect/AMQPMirrorExpiryQueueTest.java | 10 +-
.../connect/AMQPMirrorOneSideDisconnectedTest.java | 10 +-
.../amqp/connect/AMQPMirrorTemporaryQueueTest.java | 10 +-
.../amqp/connect/AMQPRedistributeClusterTest.java | 40 +-
.../integration/amqp/connect/AMQPReplicaTest.java | 5 +-
.../amqp/connect/AMQPSyncMirrorTest.java | 8 +-
.../integration/amqp/connect/AckManagerTest.java | 34 +-
.../integration/amqp/connect/BrokerInSyncTest.java | 1 -
.../integration/amqp/connect/PagedMirrorTest.java | 19 +-
.../amqp/connect/SNFPagedMirrorTest.java | 17 +-
.../amqp/journal/AmqpJournalLoadingTest.java | 3 +-
.../largemessages/InterruptedAMQPLargeMessage.java | 2 +-
.../bridge/BridgeRetryFullFailureTest.java | 3 +-
.../tests/integration/cli/QueueCommandTest.java | 3 -
.../artemis/tests/integration/cli/RecoverTest.java | 4 +-
.../integration/client/ConsumerWindowSizeTest.java | 13 +-
.../integration/client/DeleteAddressTest.java | 4 +-
.../tests/integration/client/ForceDeleteQueue.java | 3 +-
.../integration/client/InfiniteRedeliveryTest.java | 17 +-
.../client/InterruptedLargeMessageTest.java | 5 +-
.../tests/integration/client/LargeMessageTest.java | 7 +-
.../integration/client/MessageBufferTest.java | 2 +-
.../client/MessageConsumerRollbackTest.java | 3 +-
.../MessageGroupingConnectionFactoryTest.java | 3 +-
.../integration/client/MessageGroupingTest.java | 3 +-
.../client/RemoveSubscriptionRaceTest.java | 16 +-
.../tests/integration/client/SendAckFailTest.java | 2 +-
.../client/ServerLocatorConnectTest.java | 44 +-
.../tests/integration/client/UpdateQueueTest.java | 18 +-
.../integration/clientcrash/DummyInterceptor.java | 7 +-
.../clientcrash/PendingDeliveriesTest.java | 4 +-
.../cluster/bridge/BridgeReconnectTest.java | 4 +-
.../cluster/bridge/BridgeStartTest.java | 8 +-
.../integration/cluster/bridge/BridgeTest.java | 44 +-
.../bridge/BridgeWithDiscoveryGroupStartTest.java | 4 +-
.../bridge/ClusteredBridgeReconnectTest.java | 15 +-
.../cluster/bridge/NettyBridgeReconnectTest.java | 9 +-
.../crossprotocol/LargeHeadersClusterTest.java | 4 -
.../AnycastRoutingWithClusterTest.java | 10 -
.../cluster/distribution/ClusterTestBase.java | 2 +-
.../distribution/ClusteredGroupingTest.java | 5 -
.../distribution/MessageRedistributionTest.java | 2 +-
.../MessageRedistributionWithDiscoveryTest.java | 3 +-
.../PagedSNFTopicDistributionTest.java | 16 +-
.../distribution/SimpleSymmetricClusterTest.java | 4 +-
.../cluster/expiry/ClusteredExpiryTest.java | 4 +-
.../cluster/failover/AsynchronousFailoverTest.java | 4 +-
.../failover/AutomaticColocatedQuorumVoteTest.java | 4 +-
.../cluster/failover/BackupSyncJournalTest.java | 52 +-
.../ClusterWithBackupFailoverTestBase.java | 3 +-
.../cluster/failover/FailoverListenerTest.java | 5 +-
.../failover/FailoverOnFlowControlTest.java | 3 +-
.../integration/cluster/failover/FailoverTest.java | 9 +-
.../cluster/failover/FailoverTestBase.java | 4 +-
.../failover/NettyReplicatedFailoverTest.java | 24 +-
.../cluster/failover/NettyReplicationStopTest.java | 3 +-
.../failover/NetworkFailureFailoverTest.java | 5 +-
.../failover/PrimaryCrashOnBackupSyncTest.java | 2 +-
.../cluster/failover/ReplicaTimeoutTest.java | 6 +-
.../failover/ReplicatedPagedFailoverTest.java | 5 -
.../reattach/RandomReattachIntegrationTest.java | 3 +-
.../integration/cluster/reattach/ReattachTest.java | 3 +-
.../cluster/topology/IsolatedTopologyTest.java | 2 +-
.../cluster/topology/NonHATopologyTest.java | 3 +-
.../integration/cluster/util/BackupSyncDelay.java | 6 +-
.../crossprotocol/AMQPToOpenwireTest.java | 8 +-
.../crossprotocol/OpenWireToAMQPTest.java | 3 +-
.../RequestReplyMultiProtocolTest.java | 16 +-
.../tests/integration/divert/DivertTest.java | 4 +-
.../FederatedServerLocatorConfigTest.java | 3 +-
.../integration/http/CoreClientOverHttpTest.java | 3 +-
.../jdbc/store/journal/JDBCJournalTest.java | 5 -
.../jms/ActiveMQConnectionFactoryTest.java | 1 -
.../jms/ManualReconnectionToSingleServerTest.java | 5 +-
.../integration/jms/SimpleJNDIClientTest.java | 22 +-
.../integration/jms/client/ConnectionTest.java | 44 +-
.../integration/jms/client/PreACKJMSTest.java | 11 +-
.../integration/jms/client/ReSendMessageTest.java | 22 +-
.../ConnectionFactorySerializationTest.java | 8 +-
.../jms/jms2client/InvalidDestinationTest.java | 1 -
.../jms/jms2client/SharedConsumerTest.java | 2 -
.../jms/multiprotocol/JMSMessageTypesTest.java | 3 +-
.../jms/multiprotocol/JMSNonDestructiveTest.java | 6 +-
.../MultiprotocolJMSClientTestSupport.java | 7 +-
.../integration/journal/AsyncOpenCloseTest.java | 2 +-
.../integration/journal/CrashOnCompactTest.java | 4 +-
.../integration/journal/JournalHashMapTest.java | 4 +-
.../integration/journal/NIOJournalCompactTest.java | 40 +-
.../largemessage/ServerLargeMessageTest.java | 4 +-
.../management/ActiveMQServerControlTest.java | 96 +--
.../integration/management/AddressControlTest.java | 2 +-
.../integration/management/QueueControlTest.java | 14 +-
.../integration/mqtt/MQTTSecurityManagerTest.java | 22 +-
.../tests/integration/mqtt/MQTTTestSupport.java | 18 +-
.../mqtt/MqttClusterRemoteSubscribeTest.java | 4 +-
.../integration/mqtt/PahoMQTTQOS2SecurityTest.java | 2 +-
.../tests/integration/mqtt5/MQTT5TestSupport.java | 10 +-
.../mqtt5/spec/controlpackets/ConnAckTests.java | 2 +-
.../mqtt5/spec/controlpackets/ConnectTests.java | 2 +-
.../ssl/CertificateAuthenticationSslTests.java | 3 +-
.../integration/openwire/DisableAdvisoryTest.java | 3 -
.../openwire/FailoverDuplicateIDUsageTest.java | 9 +-
.../openwire/OpenWireDivertExclusiveTest.java | 2 +-
.../openwire/OpenWireDivertNonExclusiveTest.java | 4 +-
.../openwire/OpenWireLargeMessageTest.java | 4 +-
.../openwire/SessionHandlingOpenWireTest.java | 3 +-
.../integration/openwire/SimpleOpenWireTest.java | 13 +-
.../integration/openwire/amq/JMSConsumer7Test.java | 1 -
.../integration/openwire/amq/JMSConsumer8Test.java | 1 -
.../integration/openwire/amq/JMSMessageTest.java | 3 +-
.../integration/openwire/amq/JmsClientAckTest.java | 3 +-
.../openwire/amq/JmsSendReceiveTestSupport.java | 1 -
.../openwire/amq/JmsTopicRequestReplyTest.java | 3 +-
.../openwire/amq/JmsTransactionTestSupport.java | 12 +-
.../cluster/MessageRedistributionTest.java | 4 +-
.../paging/AnonymousProducerPageTest.java | 4 +-
.../paging/GlobalJournalPagingTest.java | 2 -
.../paging/PageTransactionCleanupTest.java | 3 +-
.../tests/integration/paging/PagingOrderTest.java | 11 +-
.../integration/paging/PendingTXCounterTest.java | 8 +-
.../persistence/DeleteMessagesOnStartupTest.java | 6 +-
.../integration/persistence/ExportFormatTest.java | 60 +-
.../persistence/JMSDynamicConfigTest.java | 3 +-
.../persistence/QueueConfigRestartTest.java | 3 -
.../persistence/ResizeDuplicateCacheTest.java | 4 +-
.../persistence/XmlImportExportRbacTest.java | 2 -
.../persistence/XmlImportExportTest.java | 6 +-
.../integration/plugin/BeforeSendPluginTest.java | 3 +-
.../tests/integration/plugin/CorePluginTest.java | 4 +-
.../plugin/FederationBrokerPluginTest.java | 3 +-
.../integration/plugin/MetricsPluginTest.java | 4 +-
.../ra/ActiveMQRAClusteredTestBase.java | 7 +-
.../remoting/NetworkAddressTestBase.java | 2 +-
.../replication/RepeatStartBackupTest.java | 8 +-
.../integration/replication/ReplicationTest.java | 2 +-
.../SharedNothingReplicationFlowControlTest.java | 2 +-
.../replication/SharedNothingReplicationTest.java | 2 -
.../routing/AutoClientIDShardClusterTest.java | 3 +-
.../tests/integration/routing/KeyTypeTest.java | 22 +-
.../scheduling/ScheduledMessageTest.java | 3 +-
.../security/RecursiveNettySecurityTest.java | 7 -
.../security/RejectValidatedUserTest.java | 2 +-
.../tests/integration/security/SecurityTest.java | 2 +-
.../integration/server/ResourceLimitTest.java | 2 -
.../integration/server/ScaleDown3NodeTest.java | 3 +-
.../integration/server/SimpleStartStopTest.java | 12 +-
.../ssl/CoreClientOverOneWaySSLTest.java | 2 +-
.../ssl/CoreClientOverTwoWaySSLTest.java | 2 +-
.../artemis/tests/integration/stomp/StompTest.java | 2 +-
.../stomp/StompWithClientIdValidationTest.java | 2 +-
.../stomp/StompWithInterceptorsTest.java | 2 +-
.../stomp/StompWithLargeMessagesTest.java | 4 +-
.../tests/integration/stomp/v11/StompV11Test.java | 4 +-
.../netty/NettyConnectorWithHTTPUpgradeTest.java | 9 +-
.../tests/integration/xa/SessionFailureXATest.java | 5 +-
.../tests/integration/xa/XaTimeoutTest.java | 3 +-
.../artemis/jms/tests/ActiveMQServerTestCase.java | 4 +-
.../artemis/jms/tests/ConnectionFactoryTest.java | 3 +-
.../artemis/jms/tests/message/MessageBodyTest.java | 3 +-
.../jms/tests/message/ObjectMessageTest.java | 3 +-
.../jms/tests/message/SimpleJMSBytesMessage.java | 36 +-
.../jms/tests/message/SimpleJMSMapMessage.java | 134 ++--
.../jms/tests/message/SimpleJMSStreamMessage.java | 128 ++--
.../tests/message/foreign/ForeignTestObject.java | 3 +-
.../artemis/jms/tests/tools/ServerManagement.java | 2 +-
.../jms/tests/tools/container/InVMContext.java | 7 +-
.../jms/tests/tools/container/LocalTestServer.java | 7 +-
.../artemis/jms/tests/tools/container/Server.java | 4 +-
.../activemq/artemis/common/AbstractAdmin.java | 3 -
.../artemis/common/testjndi/TestContext.java | 36 +-
.../jtests/jms/framework/JMSTestCase.java | 4 +-
.../jtests/jms/framework/PubSubTestCase.java | 2 -
.../integration/karaf/ArtemisFeatureTest.java | 4 +-
.../tests/leak/ConnectionDroppedLeakTest.java | 15 +-
.../artemis/tests/leak/ConnectionExitTest.java | 16 +-
.../artemis/tests/leak/ConnectionLeakTest.java | 5 +-
.../artemis/tests/leak/HandlerBaseLeakTest.java | 9 +-
.../artemis/tests/leak/LinkedListMemoryTest.java | 10 +-
.../tests/leak/MessageReferenceLeakTest.java | 14 +-
.../artemis/tests/leak/PagingLeakTest.java | 17 +-
.../tests/leak/ProducerBlockedLeakTest.java | 6 +-
.../artemis/tests/leak/RedistributorLeakTest.java | 13 +-
.../paging/MeasurePagingMultiThreadTest.java | 3 +-
.../bridgeTransfer/BridgeTransferingTest.java | 2 -
.../MirrorInfiniteRetryReplicaTest.java | 29 +-
.../brokerConnection/PagedMirrorSmokeTest.java | 20 +-
.../tests/smoke/console/pages/ArtemisPage.java | 2 +-
.../tests/smoke/console/pages/QueuePage.java | 2 +-
.../tests/smoke/console/pages/SendMessagePage.java | 2 +-
.../crossprotocol/MultiThreadConvertTest.java | 5 +-
.../tests/smoke/jmx2/JmxServerControlTest.java | 8 +-
.../artemis/tests/smoke/mqtt/MQTTLeakTest.java | 7 +-
.../artemis/tests/smoke/transfer/TransferTest.java | 3 +-
.../smoke/upgradeTest/CompareUpgradeTest.java | 4 +-
.../activemq/artemis/tests/soak/SoakTestBase.java | 6 -
.../mirror/ClusteredMirrorSoakTest.java | 3 +-
.../mirror/ReplicatedBothNodesMirrorTest.java | 30 +-
.../mirror/ReplicatedMirrorTargetTest.java | 16 +-
.../mirror/SingleMirrorSoakTest.java | 51 +-
.../brokerConnection/sender/SenderSoakTest.java | 3 -
.../artemis/tests/soak/client/ClientSoakTest.java | 3 +-
.../soak/clientFailure/ClientFailureSoakTest.java | 6 +-
.../clientFailure/ClientFailureSoakTestClient.java | 2 -
.../soak/interrupt/JournalFlushInterruptTest.java | 8 +-
.../soak/interruptlm/LargeMessageFrozenTest.java | 3 +-
.../artemis/tests/soak/owleak/OWLeakTest.java | 3 +-
.../tests/soak/paging/FlowControlPagingTest.java | 3 +-
.../tests/soak/paging/HorizontalPagingTest.java | 3 +-
.../tests/soak/paging/M_and_M_FactoryTest.java | 3 -
.../tests/soak/paging/SubscriptionPagingTest.java | 3 +-
.../soak/replicaTxCheck/ReplicaTXCheckTest.java | 4 +-
.../ReplicationFlowControlTest.java | 3 +-
.../soak/retention/LargeMessageRetentionTest.java | 8 +-
.../stress/journal/AddAndRemoveStressTest.java | 12 +-
.../journal/JournalCleanupCompactStressTest.java | 8 +-
.../journal/MultiThreadConsumerStressTest.java | 3 +-
.../journal/NIOMultiThreadCompactorStressTest.java | 2 +-
.../paging/MultipleConsumersPageStressTest.java | 10 +-
.../tests/stress/paging/PageStressTest.java | 5 +-
.../artemis/tests/unit/AllClassesTest.java | 4 +-
.../asyncio/MultiThreadAsynchronousFileTest.java | 3 +-
.../core/journal/impl/AlignedJournalImplTest.java | 10 +-
.../unit/core/journal/impl/BatchCommitTest.java | 8 +-
.../journal/impl/JournaHistorylBackupTest.java | 17 +-
.../unit/core/journal/impl/JournalAsyncTest.java | 5 +-
.../unit/core/message/impl/MessageImplTest.java | 12 +-
.../core/paging/impl/PagingManagerImplTest.java | 14 +-
.../unit/core/paging/impl/PagingStoreImplTest.java | 2 +-
.../persistence/impl/BatchIDGeneratorUnitTest.java | 8 +-
.../impl/DuplicateDetectionUnitTest.java | 3 +-
.../impl/WildcardAddressManagerUnitTest.java | 6 +-
.../impl/netty/NettyHandshakeTimeoutTest.java | 3 +-
.../impl/ActiveMQSecurityManagerImplTest.java | 7 +-
.../tests/unit/jms/ActiveMQDestinationTest.java | 12 +-
.../unit/jms/client/ActiveMQStreamMessageTest.java | 11 +-
.../unit/ra/ActiveMQResourceAdapterConfigTest.java | 809 +++++++++++----------
.../artemis/tests/unit/ra/ResourceAdapterTest.java | 9 +-
.../tests/unit/util/AutomaticLatchTest.java | 3 +-
.../artemis/tests/unit/util/LinkedListTest.java | 22 +-
.../util/ObjectInputStreamWithClassLoaderTest.java | 11 +-
712 files changed, 3998 insertions(+), 4169 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
