You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@activemq.apache.org by cl...@apache.org on 2021/12/10 20:50:06 UTC

[activemq-artemis] branch main updated (1581572 -> 1e62979)

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 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 [...]
     add 1e89ce8  NO-JIRA fixing intermittent test failure
     add 1e62979  ARTEMIS-3604 Async sends overflowing server in OpenWire

No new revisions were added by this update.

Summary of changes:
 .../artemis/utils/actors/ThresholdActor.java       |  96 +++++++++
 .../artemis/utils/actors/ThresholdActorTest.java   | 152 ++++++++++++++
 .../core/protocol/openwire/OpenWireConnection.java |  61 +++++-
 .../protocol/openwire/OpenWireProtocolManager.java |  32 ++-
 .../core/protocol/openwire/amq/AMQSession.java     |  24 +--
 .../activemq/artemis/core/paging/PagingStore.java  |   2 +-
 .../artemis/core/paging/impl/PagingStoreImpl.java  |   7 +-
 .../core/remoting/impl/netty/NettyAcceptor.java    |   4 +
 .../integration/client/TransactionalSendTest.java  |   2 +-
 .../storage/PersistMultiThreadTest.java            |   2 +-
 .../src/main/resources/servers/paging/broker.xml   |   2 +-
 .../smoke/paging/FloodServerWithAsyncSendTest.java | 221 +++++++++++++++++++++
 12 files changed, 579 insertions(+), 26 deletions(-)
 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
 create mode 100644 tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/FloodServerWithAsyncSendTest.java