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
