This is an automated email from the ASF dual-hosted git repository.
gtully pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git.
from 56299e8 ARTEMIS-3054 - fix lock inversion - intermittent failure of
PageCleanupWhileReplicaCatchupTest and hang
add 1581572 ARTEMIS-2097 - via elastic queue use case test based on
ARTEMIS-3365 and ARTEMIS-3569 scenario - avoid paging, if address is full chain
another broker and produce to the head, consume from the tail using producer
and consumer roles to partition connections. When tail is drained, drop it. -
adds a option to treat an idle consumer as slow - adds basic support for
credit based address blocking ARTEMIS-2097 - adds some more visiblity to
address memory usage and balancer a [...]
No new revisions were added by this update.
Summary of changes:
.../apache/activemq/artemis/logs/AuditLogger.java | 23 +
.../api/core/management/AddressControl.java | 25 +-
.../api/core/management/BrokerBalancerControl.java | 12 +
.../core/management/impl/AddressControlImpl.java | 60 ++
.../management/impl/BrokerBalancerControlImpl.java | 20 +
.../artemis/core/paging/PagingManager.java | 3 +
.../activemq/artemis/core/paging/PagingStore.java | 6 +
.../core/paging/impl/PagingManagerImpl.java | 3 +-
.../artemis/core/paging/impl/PagingStoreImpl.java | 58 +-
.../artemis/core/server/ActiveMQServerLogger.java | 9 +
.../core/server/balancing/BrokerBalancer.java | 14 +-
.../balancing/targets/TargetKeyResolver.java | 13 +-
.../core/server/embedded/EmbeddedActiveMQ.java | 4 +
.../artemis/core/server/impl/QueueImpl.java | 2 +-
docs/user-manual/en/address-model.md | 4 +-
docs/user-manual/en/management.md | 9 +-
docs/user-manual/en/slow-consumers.md | 4 +-
.../integration/amqp/AmqpFlowControlTest.java | 84 ++-
.../integration/amqp/JMSClientTestSupport.java | 2 +-
.../integration/balancing/ElasticQueueTest.java | 700 +++++++++++++++++++++
.../integration/client/MessageCounterTest.java | 3 +-
.../tests/integration/client/SlowConsumerTest.java | 35 ++
.../integration/management/AddressControlTest.java | 2 +
.../management/AddressControlUsingCoreTest.java | 15 +
.../management/BrokerBalancerControlTest.java | 25 +
.../storage/PersistMultiThreadTest.java | 13 +
.../unit/core/paging/impl/PagingStoreImplTest.java | 211 +++++++
.../artemis/tests/unit/util/FakePagingManager.java | 2 +-
28 files changed, 1333 insertions(+), 28 deletions(-)
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/balancing/ElasticQueueTest.java
