This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a change to branch 2.19.x
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git.
from e7ef539 NO-JIRA cherry-pick report between main and maintenance
branches
new da9c8d6 ARTEMIS-3529 Expire should not reject messages from
duplicateID
new ffe15b4 ARTEMIS-3461 Generalize MBean Support on Messages and avoid
converstion to core on AMQP Messages on console browsing
new b860d48 ARTEMIS-3529 Moving addItem from AMQP and Core into upper
class
new ea6b98cf ARTEMIS-3529 Fixing test and tweaks on properties
new bb3db42 ARTEMIS-3529 Fixing integration tests after Web Console
Parsing of Large Messages
new 0ce9b67 ARTEMIS-3308 - support federation of large messages
new 8d3e299 ARTEMIS-3433 - allow null return and throw error only startup
usage paths
new 696d269 ARTEMIS-3495 Fix backup cluster controller connection loops
new a85a6b6 ARTEMIS-3363 Fix TransportConfiguration extraProps encoding
new 570fd6c ARTEMIS-3363 Fix TransportConfiguration extraParams equals
new 4382382 ARTEMIS-3461 Fixing Typo on Creation Time
new 4b5eeac ARTEMIS-3540 Fix
SimpleSymmetricClusterTest.testSimpleRestartClusterConnection add bridge
connection verification after stop cluster connection to wait for the bridge
stop completely and avoid a failure on stop/start cluster connection test
new 82aeb70 ARTEMIS-3489 - fix JdbcLeaseLockTest fails sporadically in CI
new 2cd7914 ARTEMIS-3541 createQueue ignoring autoDeleteAddress flag
new 31560a7 ARTEMIS-2293 addPacket in LargeMessageControllerImpl won't
notifyAll for exception
new 56e9daf ARTEMIS-3553 -5718 Conversion of AMQP large message expiry
new b1db573 ARTEMIS-3554 Invalid Prepared Transaction could interrupt
server reload
new 3eb5685 ARTEMIS-3555 Invalid data could interrupt compacting and
shutdown server
new 669aea9 ARTEMIS-3566 Fix Stomp Embedded Interceptor Example NPE
new 00eb7e6 ARTEMIS-3567 Fix IllegalStateException on web console logout
new d65f8c5 ARTEMIS-3587 Fixing false positives on critical analyzer
new 0b482c4 ARTEMIS-3576 Fix toString methods throwing exceptions
new b4188b7 ARTEMIS-3552 NPE on message expiration
new bd671e8 ARTEMIS-3021 OOM due to wrong CORE clustered message memory
estimation
new f23aadf ARTEMIS-3577 Save Core msg re-encoding due to msg copy
new 151b59b ARTEMIS-3578 Save SimpleString duplication and long[]
allocation while moving Core messages
new e844c01 ARTEMIS-3538: Removing // --------- comments from the codebase
new e4bcade ARTEMIS-3538 Removing a few extra // ----- structural comments
new 293c3dd ARTEMIS-3538 Fixing Checkstyle
new a752de2 ARTEMIS-3538 fix extra-tests formatting and examples
compilation - Checkstyle verification fails on JMSXDeliveryCountTest because of
empty line with trailing spaces
new 914c96f ARTEMIS-3538 Removing some extra // ----
new 6af80fa ARTEMIS-3593 Defense against OME on parsing XID
new 4f9b434 fix intermittent failure of
org.apache.activemq.artemis.tests.integration.client.ConsumerTest#testSendAMQPReceiveCore
new fdbd2fa ARTEMIS-3054 - fix lock inversion - intermittent failure of
PageCleanupWhileReplicaCatchupTest and hang
new a184868 NO-JIRA fixing intermittent test failure
new 7005dcd ARTEMIS-3604 Async sends overflowing server in OpenWire
new 6ec476e ARTEMIS-3604 Small test fix on ThresholdActorTest
new 0272fe9 ARTEMIS-3604 Fixing size adjustment
new 54150aa ARTEMIS-3604 Test Improvement
new 8b643a7 ARTEMIS-3115 use correct call timeout defaults for
cluster-connection
new fd2c76d ARTEMIS-3535 bytes messages not obeying management limit
new 4a398b5 ARTEMIS-3625 Correctly compare Boolean object and fix NPE
introduced in bf875c
new cd9e1b0 NO-JIRA Fix DiscoveryTest#testSimpleBroadcast
new 5a18f8e NO-JIRA Notice update to 2022
new a3d4ca8 ARTEMIS-3636 LinkedListImpl leak on mesage consume error
new b526c9d ARTEMIS-3620 Journal blocking delete/update record with no
sync
new 0beea29 ARTEMIS-3596 Pass class loader to ServiceLoader.load to fix
OSGi issues
The 47 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:
NOTICE | 2 +-
.../cli/commands/tools/xml/XmlDataExporter.java | 2 -
.../api/core/ActiveMQInvalidBufferException.java | 14 +-
.../activemq/artemis/api/core/SimpleString.java | 9 -
.../apache/activemq/artemis/utils/ByteUtil.java | 10 +
.../apache/activemq/artemis/utils/RandomUtil.java | 16 +-
.../activemq/artemis/utils/UUIDGenerator.java | 1 -
.../apache/activemq/artemis/utils/UUIDTimer.java | 7 -
.../artemis/utils/actors/ThresholdActor.java | 96 +++++++
.../utils/collections/ConcurrentLongHashSet.java | 23 +-
.../artemis/utils/collections/TypedProperties.java | 18 +-
.../artemis/utils/critical/CriticalMeasure.java | 2 +-
.../activemq/artemis/utils/ByteUtilTest.java | 28 +-
.../artemis/utils/ConcurrentHashSetTest.java | 17 --
.../utils/TypedPropertiesConversionTest.java | 17 --
.../artemis/utils/TypedPropertiesTest.java | 2 -
.../artemis/utils/actors/ThresholdActorTest.java | 188 +++++++++++++
.../utils/critical/CriticalMeasureTest.java | 35 ++-
.../apache/activemq/artemis/api/core/JsonUtil.java | 13 +-
.../apache/activemq/artemis/api/core/Message.java | 15 +-
.../artemis/api/core/TransportConfiguration.java | 32 ++-
.../api/core/management/ActiveMQServerControl.java | 2 +-
.../api/core/management/AddressSettingsInfo.java | 4 -
.../api/core/management/DayCounterInfo.java | 4 -
.../api/core/management/ManagementHelper.java | 4 -
.../api/core/management/MessageCounterInfo.java | 3 -
.../api/core/management/ObjectNameBuilder.java | 7 +-
.../core/client/impl/ClientConsumerImpl.java | 36 +--
.../core/client/impl/ClientLargeMessageImpl.java | 4 -
.../core/client/impl/ClientProducerImpl.java | 5 -
.../core/client/impl/ClientSessionFactoryImpl.java | 4 +-
.../core/client/impl/ClientSessionImpl.java | 3 -
.../impl/CompressedLargeMessageControllerImpl.java | 7 +-
.../core/client/impl/LargeMessageController.java | 1 +
.../client/impl/LargeMessageControllerImpl.java | 18 +-
.../core/client/impl/ServerLocatorImpl.java | 5 +
.../artemis/core/message/impl/CoreMessage.java | 170 ++++++++++--
.../message}/openmbean/CompositeDataConstants.java | 2 +-
.../message/openmbean/MessageOpenTypeFactory.java | 228 +++++++++++++++
.../core/protocol/core/impl/PacketImpl.java | 6 +-
.../protocol/core/impl/RemotingConnectionImpl.java | 2 -
.../impl/wireformat/ActiveMQExceptionMessage.java | 5 -
.../wireformat/ActiveMQExceptionMessage_V2.java | 4 -
.../wireformat/ClusterTopologyChangeMessage.java | 5 -
.../core/impl/wireformat/CreateAddressMessage.java | 2 -
.../core/impl/wireformat/CreateQueueMessage.java | 1 -
.../impl/wireformat/CreateQueueMessage_V2.java | 2 -
.../core/impl/wireformat/CreateSessionMessage.java | 2 -
.../impl/wireformat/CreateSessionMessage_V2.java | 2 -
.../impl/wireformat/CreateSharedQueueMessage.java | 2 -
.../core/impl/wireformat/DisconnectMessage.java | 7 -
.../core/impl/wireformat/DisconnectMessage_V2.java | 2 -
.../core/impl/wireformat/DisconnectMessage_V3.java | 2 -
.../impl/wireformat/NullResponseMessage_V2.java | 2 -
.../impl/wireformat/PacketsConfirmedMessage.java | 2 -
.../wireformat/ReattachSessionResponseMessage.java | 2 -
.../impl/wireformat/SessionAcknowledgeMessage.java | 2 -
.../core/impl/wireformat/SessionCloseMessage.java | 2 -
.../wireformat/SessionConsumerCloseMessage.java | 2 -
.../SessionConsumerFlowCreditMessage.java | 2 -
.../wireformat/SessionContinuationMessage.java | 2 -
.../core/impl/wireformat/SessionExpireMessage.java | 7 -
.../SessionIndividualAcknowledgeMessage.java | 7 -
.../SessionReceiveContinuationMessage.java | 9 -
.../impl/wireformat/SessionReceiveMessage.java | 5 -
.../SessionRequestProducerCreditsMessage.java | 2 -
.../wireformat/SessionSendContinuationMessage.java | 4 -
.../SessionSendContinuationMessage_V2.java | 4 -
.../impl/wireformat/SessionSendLargeMessage.java | 5 -
.../core/impl/wireformat/SessionSendMessage.java | 2 -
.../SessionUniqueAddMetaDataMessage.java | 17 --
.../wireformat/SessionXAAfterFailedMessage.java | 7 -
.../impl/wireformat/SessionXAResponseMessage.java | 2 -
.../wireformat/SessionXAResponseMessage_V2.java | 2 -
.../impl/wireformat/SessionXAResumeMessage.java | 2 -
.../impl/wireformat/SessionXARollbackMessage.java | 2 -
.../wireformat/SessionXASetTimeoutMessage.java | 2 -
.../SessionXASetTimeoutResponseMessage.java | 2 -
.../impl/wireformat/SessionXAStartMessage.java | 7 -
.../SubscribeClusterTopologyUpdatesMessage.java | 2 -
.../SubscribeClusterTopologyUpdatesMessageV2.java | 2 -
.../core/remoting/impl/netty/NettyConnection.java | 4 +
.../core/remoting/impl/netty/NettyConnector.java | 25 +-
.../impl/ssl/CachingOpenSSLContextFactory.java | 13 +-
.../impl/ssl/DefaultOpenSSLContextFactory.java | 13 +-
.../artemis/core/remoting/impl/ssl/SSLSupport.java | 1 -
.../artemis/core/transaction/impl/XidImpl.java | 8 +-
.../artemis/core/version/impl/VersionImpl.java | 2 +-
.../core/remoting/ssl/OpenSSLContextFactory.java | 13 +-
.../ssl/OpenSSLContextFactoryProvider.java | 18 +-
.../spi/core/remoting/ssl/SSLContextConfig.java | 13 +-
.../remoting/ssl/SSLContextFactoryProvider.java | 2 +-
.../artemis/utils/ActiveMQBufferInputStream.java | 15 -
.../activemq/artemis/utils/AutoCreateUtil.java | 13 +-
.../activemq/artemis/utils/BufferHelper.java | 23 ++
.../apache/activemq/artemis/utils/JNDIUtil.java | 16 --
.../utils/ObjectInputStreamWithClassLoader.java | 14 -
.../activemq/artemis/utils/SizeFormatterUtil.java | 17 --
.../artemis/utils/SoftValueLongObjectHashMap.java | 16 +-
.../artemis/utils/TimeAndCounterIDGenerator.java | 14 +-
.../org/apache/activemq/artemis/utils/XMLUtil.java | 2 -
.../activemq/artemis/utils/XidCodecSupport.java | 25 +-
.../api/core/TransportConfigurationTest.java | 67 +++++
.../activemq/artemis/message/CoreMessageTest.java | 31 +++
.../ssl/OpenSSLContextFactoryProviderTest.java | 13 +-
.../util/TimeAndCounterIDGeneratorTest.java | 10 -
.../apache/activemq/artemis/util/XMLUtilTest.java | 2 -
.../activemq/artemis/util/XidCodecSupportTest.java | 76 +++++
.../src/main/resources/licenses/bin/NOTICE | 2 +-
.../artemis/jms/client/ActiveMQBytesMessage.java | 6 -
.../artemis/jms/client/ActiveMQConnection.java | 17 +-
.../jms/client/ActiveMQConnectionFactory.java | 5 -
.../jms/client/ActiveMQConnectionMetaData.java | 6 +-
.../artemis/jms/client/ActiveMQDestination.java | 14 +-
.../artemis/jms/client/ActiveMQMapMessage.java | 11 -
.../artemis/jms/client/ActiveMQMessage.java | 25 +-
.../jms/client/ActiveMQMessageConsumer.java | 8 +-
.../jms/client/ActiveMQMessageProducer.java | 2 -
.../artemis/jms/client/ActiveMQObjectMessage.java | 7 +-
.../activemq/artemis/jms/client/ActiveMQQueue.java | 12 -
.../artemis/jms/client/ActiveMQQueueBrowser.java | 15 +-
.../artemis/jms/client/ActiveMQSession.java | 10 +-
.../artemis/jms/client/ActiveMQStreamMessage.java | 3 -
.../artemis/jms/client/ActiveMQTemporaryQueue.java | 14 +-
.../artemis/jms/client/ActiveMQTemporaryTopic.java | 14 -
.../artemis/jms/client/ActiveMQTextMessage.java | 6 -
.../activemq/artemis/jms/client/ActiveMQTopic.java | 13 +-
.../jms/bridge/impl/JMSBridgeControlImpl.java | 15 -
.../artemis/jms/bridge/impl/JMSBridgeImpl.java | 10 +-
.../jms/persistence/config/PersistedBindings.java | 15 -
.../config/PersistedConnectionFactory.java | 15 -
.../persistence/config/PersistedDestination.java | 15 -
.../impl/journal/JMSJournalStorageManagerImpl.java | 10 +-
.../impl/ConnectionFactoryConfigurationImpl.java | 15 -
.../config/impl/JMSQueueConfigurationImpl.java | 15 -
.../server/config/impl/TopicConfigurationImpl.java | 16 --
.../TransportConfigurationEncodingSupport.java | 16 --
.../jms/server/impl/JMSServerManagerImpl.java | 4 +-
.../artemis/core/io/AbstractSequentialFile.java | 1 -
.../artemis/core/io/aio/AIOSequentialFile.java | 3 -
.../artemis/core/io/buffer/TimedBuffer.java | 16 +-
.../core/journal/JournalUpdateCallback.java | 2 +-
.../journal/impl/AbstractJournalUpdateTask.java | 11 -
.../core/journal/impl/JournalFilesRepository.java | 1 -
.../artemis/core/journal/impl/JournalImpl.java | 46 +++-
.../artemis/core/journal/impl/JournalRecord.java | 4 +
.../core/journal/impl/SyncIOCompletion.java | 16 --
.../journal/impl/dataformat/ByteArrayEncoding.java | 1 -
.../protocol/amqp/broker/AMQPLargeMessage.java | 15 +-
.../artemis/protocol/amqp/broker/AMQPMessage.java | 212 +++++++++++++-
.../coreWrapper/CoreStreamMessageWrapper.java | 2 -
.../coreWrapper/CoreTextMessageWrapper.java | 5 +-
.../artemis/protocol/amqp/util/NettyReadable.java | 4 +
.../protocol/amqp/converter/TestConversions.java | 4 +-
.../core/protocol/openwire/OpenWireConnection.java | 62 ++++-
.../protocol/openwire/OpenWireProtocolManager.java | 32 ++-
.../core/protocol/openwire/amq/AMQSession.java | 24 +-
.../core/protocol/stomp/StompProtocolManager.java | 4 -
.../artemis/core/protocol/stomp/StompUtils.java | 14 -
.../ra/ActiveMQRAManagedConnectionFactory.java | 2 +-
.../activemq/artemis/ra/ActiveMQRAMessage.java | 5 +
.../activemq/artemis/ra/ActiveMQRAService.java | 13 -
.../artemis/ra/recovery/RecoveryManager.java | 2 +-
.../core/config/impl/ConfigurationImpl.java | 5 -
.../deployers/impl/FileConfigurationParser.java | 5 +-
.../artemis/core/filter/impl/FilterImpl.java | 6 -
.../core/management/impl/AbstractControl.java | 11 +-
.../core/management/impl/AcceptorControlImpl.java | 15 -
.../management/impl/ActiveMQServerControlImpl.java | 12 +-
.../core/management/impl/AddressControlImpl.java | 10 -
.../impl/BaseBroadcastGroupControlImpl.java | 16 --
.../core/management/impl/BridgeControlImpl.java | 15 -
.../management/impl/BroadcastGroupControlImpl.java | 14 -
.../impl/ClusterConnectionControlImpl.java | 13 -
.../core/management/impl/DivertControlImpl.java | 15 -
.../JGroupsChannelBroadcastGroupControlImpl.java | 16 --
.../impl/JGroupsFileBroadcastGroupControlImpl.java | 14 -
...JGroupsPropertiesBroadcastGroupControlImpl.java | 15 -
.../core/management/impl/MBeanInfoHelper.java | 11 -
.../core/management/impl/QueueControlImpl.java | 22 +-
.../impl/openmbean/CompositeDataConstants.java | 63 +----
.../management/impl/openmbean/OpenTypeSupport.java | 305 ---------------------
.../core/messagecounter/MessageCounter.java | 10 -
.../messagecounter/impl/MessageCounterHelper.java | 13 -
.../activemq/artemis/core/paging/PagingStore.java | 2 +-
.../paging/cursor/impl/PageCursorProviderImpl.java | 7 +-
.../core/paging/cursor/impl/PageReader.java | 4 +
.../paging/cursor/impl/PageSubscriptionImpl.java | 5 -
.../activemq/artemis/core/paging/impl/Page.java | 2 -
.../artemis/core/paging/impl/PageSyncTimer.java | 6 -
.../core/paging/impl/PageTransactionInfoImpl.java | 15 -
.../core/paging/impl/PagingManagerImpl.java | 4 -
.../paging/impl/PagingStoreFactoryDatabase.java | 4 +-
.../core/paging/impl/PagingStoreFactoryNIO.java | 3 -
.../artemis/core/paging/impl/PagingStoreImpl.java | 10 +-
.../config/PersistedAddressSetting.java | 14 -
.../core/persistence/config/PersistedRole.java | 15 +-
.../config/PersistedSecuritySetting.java | 15 -
.../journal/AbstractJournalStorageManager.java | 290 +++++++++++---------
.../impl/journal/BatchingIDGenerator.java | 1 -
.../persistence/impl/journal/BufferSplitter.java | 1 -
.../impl/journal/JournalStorageManager.java | 2 +-
.../core/persistence/impl/journal/LargeBody.java | 2 +
.../impl/journal/LargeServerMessageImpl.java | 21 +-
.../impl/journal/codec/DuplicateIDEncoding.java | 7 +-
.../codec/PersistentAddressBindingEncoding.java | 5 +
.../impl/nullpm/NullStorageLargeServerMessage.java | 2 +-
.../core/postoffice/impl/PostOfficeImpl.java | 2 -
.../BackupReplicationStartFailedMessage.java | 7 +-
.../core/impl/wireformat/NodeAnnounceMessage.java | 3 -
.../impl/wireformat/ReplicationAddMessage.java | 1 -
.../impl/wireformat/ReplicationAddTXMessage.java | 1 -
.../wireformat/ReplicationPageWriteMessage.java | 1 -
.../impl/wireformat/ReplicationPrepareMessage.java | 1 -
.../core/remoting/impl/netty/NettyAcceptor.java | 13 +-
.../remoting/server/impl/RemotingServiceImpl.java | 6 -
.../core/replication/ReplicationEndpoint.java | 3 +-
.../core/replication/ReplicationManager.java | 1 -
.../core/security/impl/SecurityStoreImpl.java | 1 -
.../artemis/core/server/ActiveMQServer.java | 4 +-
.../artemis/core/server/ActiveMQServerLogger.java | 15 +-
.../artemis/core/server/cluster/BackupManager.java | 7 +
.../core/server/cluster/ClusterController.java | 10 +-
.../core/server/cluster/ClusterManager.java | 2 +-
.../core/server/cluster/impl/BridgeImpl.java | 5 +-
.../server/cluster/impl/ClusterConnectionImpl.java | 10 +-
.../core/server/cluster/qourum/QuorumManager.java | 5 +
.../federation/FederatedQueueConsumerImpl.java | 26 +-
.../core/server/impl/ActiveMQServerImpl.java | 23 +-
.../artemis/core/server/impl/DivertImpl.java | 2 +-
.../core/server/impl/MessageReferenceImpl.java | 17 +-
.../artemis/core/server/impl/QueueImpl.java | 60 ++--
.../artemis/core/server/impl/QueueManagerImpl.java | 2 +-
.../core/server/impl/ServerConsumerImpl.java | 10 +-
.../artemis/core/server/impl/ServerInfo.java | 1 -
.../core/server/impl/ServerSessionImpl.java | 8 +-
.../management/impl/ManagementServiceImpl.java | 6 -
.../core/security/ActiveMQSecurityManagerImpl.java | 2 +-
.../core/config/impl/FileConfigurationTest.java | 2 +
.../artemis/core/config/impl/ValidatorsTest.java | 10 -
.../artemis/core/filter/impl/FilterTest.java | 2 -
.../impl/openmbean/OpenTypeSupportTest.java | 3 +-
.../impl/journal/OperationContextUnitTest.java | 8 -
.../activemq/artemis/core/security/RoleTest.java | 13 -
.../core/server/impl/jdbc/JdbcLeaseLockTest.java | 2 +-
.../artemis/core/version/impl/VersionImplTest.java | 14 -
.../artemis/tests/util/ActiveMQTestBase.java | 2 -
.../artemis/component/AuthenticationFilter.java | 7 +-
.../artemis/jms/example/TextReverserService.java | 15 -
.../activemq/artemis/jms/example/DummyXid.java | 6 +-
.../activemq/artemis/jms/example/DummyXid.java | 7 +-
.../activemq/artemis/jms/example/DummyXid.java | 6 -
.../src/main/resources/activemq/server0/broker.xml | 2 +-
.../broker/artemiswrapper/InVMNameParser.java | 14 -
.../broker/artemiswrapper/InVMNamingContext.java | 9 -
.../apache/activemq/perf/NetworkedSyncTest.java | 1 -
.../amqp/client/AmqpTransactionCoordinator.java | 2 -
.../main/resources/meshTest/sendMessages.groovy | 10 +-
.../{SendAckTest.java => Mesh2Test.java} | 52 ++--
.../tests/extras/jms/bridge/BridgeTestBase.java | 1 -
.../tests/extras/jms/bridge/JMSBridgeTest.java | 3 -
.../tests/extras/jms/xa/JMSXDeliveryCountTest.java | 8 -
.../artemis/tests/extras/jms/xa/XATest.java | 8 -
.../integration/SimpleNotificationService.java | 15 -
.../tests/integration/String64KLimitTest.java | 6 -
.../integration/amqp/AmqpExpiredMessageTest.java | 81 +++++-
.../tests/integration/amqp/JMXManagementTest.java | 22 +-
.../tests/integration/amqp/TopicDurableTests.java | 6 +
.../SimpleStreamingLargeMessageTest.java | 3 +-
.../tests/integration/client/BlockingSendTest.java | 8 -
.../integration/client/ConsumerCloseTest.java | 5 -
.../client/CreateQueueIdempotentTest.java | 8 -
.../tests/integration/client/DurableQueueTest.java | 9 -
.../client/ExpireTestOnRestartTest.java | 8 -
.../integration/client/ExpiryLargeMessageTest.java | 16 +-
.../tests/integration/client/HeuristicXATest.java | 12 -
.../client/IncompatibleVersionTest.java | 6 -
.../client/InterruptedLargeMessageTest.java | 2 +-
.../integration/client/InvalidCoreClientTest.java | 161 +++++++++++
.../integration/client/JmsNettyNioStressTest.java | 16 --
.../client/LargeMessageCompressTest.java | 2 +-
.../tests/integration/client/LargeMessageTest.java | 4 -
.../client/LibaioDependencyCheckTest.java | 16 --
.../client/MessageConsumerRollbackTest.java | 8 -
.../integration/client/MessageDurabilityTest.java | 11 -
.../integration/client/MessageExpirationTest.java | 2 -
.../integration/client/MessagePriorityTest.java | 11 -
.../tests/integration/client/MessageRateTest.java | 7 -
.../tests/integration/client/MixRoutingTest.java | 7 +-
.../client/MultipleThreadFilterOneTest.java | 16 +-
.../tests/integration/client/NIOvsOIOTest.java | 8 -
.../client/NettyConsumerWindowSizeTest.java | 15 -
.../tests/integration/client/OrderTest.java | 12 -
.../integration/client/ProducerCloseTest.java | 2 -
.../integration/client/RedeliveryConsumerTest.java | 9 -
.../client/SelfExpandingBufferTest.java | 2 -
.../tests/integration/client/SessionCloseTest.java | 10 -
.../integration/client/TemporaryQueueTest.java | 2 -
.../integration/client/TransactionalSendTest.java | 2 +-
.../integration/clientcrash/ClientCrashTest.java | 8 -
.../integration/clientcrash/ClientExitTest.java | 12 +-
.../tests/integration/clientcrash/CrashClient.java | 19 --
.../integration/clientcrash/CrashClient2.java | 19 --
.../integration/clientcrash/GracefulClient.java | 19 --
.../cluster/distribution/ClusterTestBase.java | 2 -
.../distribution/SimpleSymmetricClusterTest.java | 28 +-
.../TwoWayTwoNodeClusterWithDiscoveryTest.java | 11 -
.../integration/cluster/failover/FailoverTest.java | 60 +++-
.../cluster/failover/FailoverTestBase.java | 4 -
.../failover/MultipleServerFailoverTestBase.java | 3 +-
.../PageCleanupWhileReplicaCatchupTest.java | 2 +-
.../cluster/failover/PagingFailoverTest.java | 9 +-
.../MultiThreadRandomReattachTestBase.java | 10 -
.../MultiThreadReattachSupportTestBase.java | 2 -
.../cluster/reattach/OrderReattachTest.java | 6 -
.../cluster/reattach/RandomReattachTest.java | 10 -
.../integration/cluster/reattach/ReattachTest.java | 4 -
.../tests/integration/discovery/DiscoveryTest.java | 3 +-
.../integration/federation/FederatedQueueTest.java | 29 +-
.../tests/integration/jms/FloodServerTest.java | 17 +-
.../jms/ManualReconnectionToSingleServerTest.java | 6 +-
.../integration/jms/client/CreateQueueTest.java | 7 -
.../integration/jms/client/ExpiryMessageTest.java | 11 -
.../tests/integration/jms/client/MessageTest.java | 12 +-
.../jms/client/MoveMessageDuplicateIDTest.java | 213 ++++++++++++++
.../jms/client/NewQueueRequestorTest.java | 8 -
.../jms/client/NoLocalSubscriberTest.java | 8 -
.../integration/jms/client/PreACKJMSTest.java | 11 -
.../integration/jms/client/ReSendMessageTest.java | 11 -
...ssionClosedOnRemotingConnectionFailureTest.java | 13 -
.../integration/jms/client/StoreConfigTest.java | 8 -
.../jms/client/TemporaryDestinationTest.java | 38 +++
.../integration/jms/client/TextMessageTest.java | 9 -
.../jms/cluster/JMSFailoverListenerTest.java | 11 -
.../integration/jms/cluster/JMSFailoverTest.java | 11 -
.../integration/jms/cluster/JMSReconnectTest.java | 4 -
.../jms/cluster/TemporaryQueueClusterTest.java | 16 --
.../integration/jms/cluster/TopicClusterTest.java | 15 -
.../ConnectionFactorySerializationTest.java | 10 -
...nectionFactoryWithJGroupsSerializationTest.java | 1 -
.../jms/largemessage/JMSLargeMessageTest.java | 13 -
.../jms/server/JMSServerDeployerTest.java | 12 +-
.../server/config/JMSServerConfigParserTest.java | 15 -
.../integration/jms/server/management/JMSUtil.java | 15 -
.../integration/journal/NIOImportExportTest.java | 16 --
.../integration/journal/NIOJournalCompactTest.java | 49 ++++
.../journal/ValidateTransactionHealthTest.java | 3 -
.../largemessage/LargeMessageTestBase.java | 10 -
.../largemessage/ServerLargeMessageTest.java | 18 +-
.../management/AcceptorControlTest.java | 5 -
.../management/AcceptorControlUsingCoreTest.java | 8 -
.../management/ActiveMQServerControlTest.java | 40 ++-
.../ActiveMQServerControlUsingCoreTest.java | 16 --
.../integration/management/AddressControlTest.java | 6 -
.../management/AddressControlUsingCoreTest.java | 10 -
.../management/BridgeControlUsingCoreTest.java | 8 -
.../management/ClusterConnectionControl2Test.java | 6 +-
.../management/ClusterConnectionControlTest.java | 10 -
.../ClusterConnectionControlUsingCoreTest.java | 17 --
.../integration/management/CoreMessagingProxy.java | 11 -
.../integration/management/DivertControlTest.java | 7 -
.../management/DivertControlUsingCoreTest.java | 16 --
.../management/ManagementControlHelper.java | 13 -
.../management/ManagementHelperTest.java | 16 --
.../management/ManagementServiceImplTest.java | 6 -
.../integration/management/ManagementTestBase.java | 12 +-
.../integration/management/NotificationTest.java | 10 -
.../integration/management/QueueControlTest.java | 175 +++++++++++-
.../management/SSLSecurityNotificationTest.java | 2 -
.../management/SecurityManagementTestBase.java | 11 -
...urityManagementWithConfiguredAdminUserTest.java | 9 -
...rityManagementWithDefaultConfigurationTest.java | 4 -
...ityManagementWithModifiedConfigurationTest.java | 11 -
.../management/SecurityNotificationTest.java | 11 -
.../integration/paging/PagingCounterTest.java | 7 -
.../tests/integration/paging/PagingOrderTest.java | 3 -
.../tests/integration/paging/PagingSyncTest.java | 10 -
.../tests/integration/paging/PagingTest.java | 106 +++++++
.../persistence/DeleteQueueRestartTest.java | 16 +-
.../integration/persistence/ExportFormatTest.java | 11 -
.../persistence/JMSDynamicConfigTest.java | 16 --
.../persistence/QueueConfigRestartTest.java | 15 -
.../integration/persistence/RestartSMTest.java | 13 -
.../persistence/RolesConfigurationStorageTest.java | 8 -
.../TransportConfigurationEncodingSupportTest.java | 17 --
.../integration/ra/ActiveMQActivationTest.java | 16 --
.../integration/remoting/DestroyConsumerTest.java | 16 --
.../remoting/NettyNetworkAddressTest.java | 2 -
.../remoting/NetworkAddressTestBase.java | 11 -
.../tests/integration/remoting/PingTest.java | 6 -
.../tests/integration/remoting/ReconnectTest.java | 8 -
.../integration/remoting/SynchronousCloseTest.java | 6 -
.../integration/replication/ReplicationTest.java | 2 -
.../integration/scheduling/DelayedMessageTest.java | 1 -
.../scheduling/MultipliedDelayedMessageTest.java | 1 -
.../scheduling/ScheduledMessageTest.java | 1 -
.../ssl/CoreClientOverOneWaySSLTest.java | 2 -
.../ssl/CoreClientOverTwoWaySSLTest.java | 2 -
.../artemis/tests/util/JMSClusteredTestBase.java | 19 --
.../artemis/jms/tests/AcknowledgementTest.java | 8 -
.../jms/tests/AutoAckMessageListenerTest.java | 15 -
.../artemis/jms/tests/CTSMiscellaneousTest.java | 12 -
.../artemis/jms/tests/ConnectionClosedTest.java | 18 --
.../activemq/artemis/jms/tests/ConnectionTest.java | 18 --
.../artemis/jms/tests/ConsumerClosedTest.java | 14 +-
.../artemis/jms/tests/DurableSubscriptionTest.java | 7 -
.../artemis/jms/tests/MessageConsumerTest.java | 6 -
.../artemis/jms/tests/MessageProducerTest.java | 6 -
.../jms/tests/MessageWithReadResolveTest.java | 15 -
.../artemis/jms/tests/MiscellaneousTest.java | 16 --
.../jms/tests/NonDurableSubscriberTest.java | 15 -
.../artemis/jms/tests/ReferenceableTest.java | 7 -
.../activemq/artemis/jms/tests/SessionTest.java | 7 -
.../jms/tests/TemporaryDestinationTest.java | 13 -
.../activemq/artemis/jms/tests/TopicTest.java | 15 -
.../artemis/jms/tests/TransactedSessionTest.java | 6 -
.../jms/tests/message/BytesMessageTest.java | 7 -
.../tests/message/JMSCorrelationIDHeaderTest.java | 11 -
.../tests/message/JMSDeliveryModeHeaderTest.java | 16 --
.../tests/message/JMSDestinationHeaderTest.java | 13 -
.../jms/tests/message/JMSExpirationHeaderTest.java | 14 -
.../jms/tests/message/JMSMessageIDHeaderTest.java | 13 -
.../jms/tests/message/JMSReplyToHeaderTest.java | 15 -
.../jms/tests/message/JMSTimestampHeaderTest.java | 15 -
.../jms/tests/message/JMSTypeHeaderTest.java | 15 -
.../artemis/jms/tests/message/MapMessageTest.java | 8 -
.../jms/tests/message/MessageHeaderTest.java | 15 -
.../jms/tests/message/MessageHeaderTestBase.java | 4 -
.../message/MessagePropertyConversionTest.java | 5 +-
.../artemis/jms/tests/message/MessageTestBase.java | 11 -
.../tests/message/ObjectMessageDeliveryTest.java | 15 -
.../jms/tests/message/SimpleJMSBytesMessage.java | 8 -
.../jms/tests/message/SimpleJMSMapMessage.java | 9 -
.../jms/tests/message/SimpleJMSMessage.java | 9 +-
.../jms/tests/message/SimpleJMSObjectMessage.java | 12 -
.../jms/tests/message/SimpleJMSStreamMessage.java | 12 -
.../jms/tests/message/SimpleJMSTextMessage.java | 12 -
.../jms/tests/message/StreamMessageTest.java | 8 -
.../artemis/jms/tests/message/TextMessageTest.java | 8 -
.../artemis/jms/tests/selector/SelectorTest.java | 6 -
.../artemis/jms/tests/tools/ServerManagement.java | 3 +-
.../jms/tests/tools/container/Constants.java | 13 +-
.../jms/tests/tools/container/InVMContext.java | 9 -
.../tools/container/InVMInitialContextFactory.java | 13 -
.../InVMInitialContextFactoryBuilder.java | 21 +-
.../jms/tests/tools/container/InVMNameParser.java | 16 +-
.../jms/tests/tools/container/LocalTestServer.java | 15 +-
.../artemis/jms/tests/util/JNDIUtilTest.java | 10 -
.../activemq/artemis/common/SpawnedJMSServer.java | 9 -
.../activemq/artemis/jms/ActiveMQCoreAdmin.java | 1 -
.../performance/jmh/JournalSyncDeletePerfTest.java | 128 +++++++++
.../paging/MeasurePagingMultiThreadTest.java | 4 -
.../storage/PersistMultiThreadTest.java | 2 +-
.../src/main/resources/servers/paging/broker.xml | 2 +-
.../smoke/paging/FloodServerWithAsyncSendTest.java | 221 +++++++++++++++
.../artemis/tests/soak/client/ClientAbstract.java | 15 +-
.../soak/client/ClientNonDivertedSoakTest.java | 15 -
.../artemis/tests/soak/client/ClientSoakTest.java | 14 -
.../artemis/tests/soak/client/Receiver.java | 16 --
.../activemq/artemis/tests/soak/client/Sender.java | 16 --
.../soak/client/SimpleSendReceiveSoakTest.java | 7 -
.../tests/stress/chunk/LargeMessageStressTest.java | 16 --
.../tests/stress/client/SendStressTest.java | 16 --
.../stress/failover/RandomReattachStressTest.java | 12 -
.../AIOAllPossibilitiesCompactStressTest.java | 14 -
.../stress/journal/AddAndRemoveStressTest.java | 7 +-
.../tests/stress/journal/CompactingStressTest.java | 5 -
.../journal/JournalCleanupCompactStressTest.java | 16 --
.../stress/journal/JournalRestartStressTest.java | 15 -
.../stress/journal/LargeJournalStressTest.java | 14 -
.../stress/journal/MixupCompactorTestBase.java | 7 -
.../journal/MultiThreadConsumerStressTest.java | 15 -
.../journal/NIOMultiThreadCompactorStressTest.java | 14 -
.../paging/MultipleConsumersPageStressTest.java | 15 -
.../tests/stress/paging/PageCursorStressTest.java | 4 -
.../tests/stress/paging/PageStressTest.java | 2 -
.../core/server/impl/QueueConcurrentTest.java | 2 -
.../timing/jms/bridge/impl/JMSBridgeImplTest.java | 10 -
.../artemis/tests/timing/util/UUIDTest.java | 5 -
tests/unit-tests/pom.xml | 4 +
.../artemis/tests/unit/AllClassesTest.java | 138 ++++++++++
.../core/client/impl/LargeMessageBufferTest.java | 43 +--
.../config/impl/ConfigurationValidationTest.java | 8 -
.../config/impl/TransportConfigurationTest.java | 16 --
.../core/journal/impl/AlignedJournalImplTest.java | 12 +-
.../unit/core/journal/impl/CleanBufferTest.java | 16 --
.../unit/core/journal/impl/JournalAsyncTest.java | 11 -
.../impl/SequentialFileFactoryTestBase.java | 2 -
.../unit/core/journal/impl/TimedBufferTest.java | 6 -
.../impl/fakes/FakeSequentialFileFactory.java | 5 -
.../core/journal/impl/fakes/SimpleEncoding.java | 15 -
.../unit/core/message/impl/MessageImplTest.java | 3 -
.../unit/core/paging/impl/PagePositionTest.java | 16 --
.../tests/unit/core/paging/impl/PageTest.java | 8 -
.../impl/DuplicateDetectionUnitTest.java | 7 -
.../unit/core/remoting/ActiveMQBufferTestBase.java | 12 -
.../impl/netty/ChannelBufferWrapper2Test.java | 14 -
.../core/remoting/impl/ssl/SSLSupportTest.java | 7 -
.../group/impl/SystemPropertyOverrideTest.java | 7 -
.../tests/unit/core/server/impl/QueueImplTest.java | 2 -
.../tests/unit/jms/ActiveMQDestinationTest.java | 13 -
.../unit/jms/client/ActiveMQMapMessageTest.java | 6 -
.../unit/jms/client/ActiveMQStreamMessageTest.java | 9 -
.../unit/jms/client/JMSExceptionHelperTest.java | 7 -
.../unit/jms/client/SelectorTranslatorTest.java | 2 -
.../artemis/tests/unit/jms/misc/ManifestTest.java | 9 -
.../artemis/tests/unit/ra/ResourceAdapterTest.java | 8 -
.../DestinationObjectFactoryTest.java | 13 -
.../artemis/tests/unit/util/InVMContext.java | 11 +-
.../artemis/tests/unit/util/InVMNameParser.java | 14 +-
.../artemis/tests/unit/util/InVMNamingContext.java | 9 -
.../util/ObjectInputStreamWithClassLoaderTest.java | 11 -
.../artemis/tests/unit/util/SoftValueMapTest.java | 15 -
.../artemis/tests/unit/util/UUIDGeneratorTest.java | 13 -
.../artemis/tests/unit/util/VersionLoaderTest.java | 18 --
515 files changed, 3466 insertions(+), 4392 deletions(-)
copy
artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/TransportConfigurationHelper.java
=>
artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidBufferException.java
(74%)
create mode 100644
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/actors/ThresholdActor.java
create mode 100644
artemis-commons/src/test/java/org/apache/activemq/artemis/utils/actors/ThresholdActorTest.java
copy
{artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl
=>
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message}/openmbean/CompositeDataConstants.java
(97%)
create mode 100644
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/openmbean/MessageOpenTypeFactory.java
create mode 100644
artemis-core-client/src/test/java/org/apache/activemq/artemis/util/XidCodecSupportTest.java
delete mode 100644
artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/openmbean/OpenTypeSupport.java
copy
tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/{SendAckTest.java
=> Mesh2Test.java} (66%)
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/InvalidCoreClientTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/client/MoveMessageDuplicateIDTest.java
create mode 100644
tests/performance-jmh/src/main/java/org/apache/activemq/artemis/tests/performance/jmh/JournalSyncDeletePerfTest.java
create mode 100644
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/FloodServerWithAsyncSendTest.java
create mode 100644
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/AllClassesTest.java
