This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
from fad1f5274c ARTEMIS-4799 Fix broker connection receiver attach handling
add 5be983392c ARTEMIS-4798 Use original message to calculate the Mirror
SNF size in order to start paging
No new revisions were added by this update.
Summary of changes:
.../activemq/artemis/utils/SizeAwareMetric.java | 7 +-
.../apache/activemq/artemis/api/core/Message.java | 6 +
.../protocol/amqp/broker/AMQPLargeMessage.java | 1 +
.../artemis/protocol/amqp/broker/AMQPMessage.java | 12 ++
.../protocol/amqp/broker/AMQPStandardMessage.java | 1 +
.../activemq/artemis/core/paging/PagingStore.java | 10 +-
.../artemis/core/paging/impl/PagingStoreImpl.java | 9 +-
.../artemis/core/server/impl/QueueImpl.java | 25 ++-
.../integration/amqp/connect/AMQPReplicaTest.java | 87 ++++++++-
.../integration/amqp/connect/BrokerInSyncTest.java | 26 ++-
.../storage/PersistMultiThreadTest.java | 7 +-
.../brokerConnection/PagedMirrorSmokeTest.java | 26 +--
.../mirror/AccumulatedInPageSoakTest.java | 214 +++++++++++++++++++++
.../brokerConnection/mirror/PagedSNFSoakTest.java | 3 -
14 files changed, 386 insertions(+), 48 deletions(-)
create mode 100644
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/AccumulatedInPageSoakTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
