You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2021/12/09 10:14:25 UTC

[activemq-artemis] branch main updated (56299e8 -> 1581572)

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