This is an automated email from the ASF dual-hosted git repository.
robbie pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
from 8afa3d8a41 ARTEMIS-5156 Wait.assertEquals on messageCount
add e9c06bd9f8 ARTEMIS-5157 Add management for AMQP broker connections
No new revisions were added by this update.
Summary of changes:
.../apache/activemq/artemis/logs/AuditLogger.java | 57 +++
.../core/management/BrokerConnectionControl.java | 66 +++
.../api/core/management/ObjectNameBuilder.java | 23 +
.../artemis/api/core/management/ResourceNames.java | 2 +
.../amqp/connect/AMQPBrokerConnection.java | 86 ++--
.../amqp/connect/AMQPBrokerConnectionManager.java | 4 +
.../amqp/connect/federation/AMQPFederation.java | 74 ++-
.../federation/AMQPFederationAddressConsumer.java | 201 +++-----
.../AMQPFederationAddressPolicyControl.java | 88 ++++
.../AMQPFederationAddressPolicyManager.java | 23 +-
.../connect/federation/AMQPFederationConsumer.java | 175 +++++++
.../federation/AMQPFederationConsumerControl.java} | 46 +-
.../AMQPFederationConsumerControlType.java | 156 ++++++
.../AMQPFederationManagementSupport.java | 193 +++++++
.../federation/AMQPFederationPolicyControl.java} | 24 +-
.../federation/AMQPFederationQueueConsumer.java | 206 +++-----
.../AMQPFederationQueuePolicyControl.java | 88 ++++
.../AMQPFederationQueuePolicyManager.java | 23 +-
.../connect/federation/AMQPFederationSource.java | 50 +-
.../connect/federation/AMQPFederationTarget.java | 2 +-
.../FederationReceiveFromAddressPolicy.java | 10 +-
.../FederationReceiveFromQueuePolicy.java | 10 +-
...va => FederationReceiveFromResourcePolicy.java} | 27 +-
.../{Federation.java => FederationType.java} | 28 +-
.../internal/FederationAddressPolicyManager.java | 88 +---
.../internal/FederationPolicyManager.java | 140 ++++++
.../internal/FederationQueuePolicyManager.java | 81 +--
.../management/impl/ActiveMQServerControlImpl.java | 2 +
.../impl/BrokerConnectionControlImpl.java | 177 +++++++
.../artemis/core/server/BrokerConnection.java | 5 +
.../core/server/management/ManagementService.java | 6 +
.../management/impl/ManagementServiceImpl.java | 16 +
.../server/group/impl/ClusteredResetMockTest.java | 12 +-
.../amqp/connect/AMQPFederationConnectTest.java | 72 +++
.../amqp/connect/AMQPFederationManagementTest.java | 559 +++++++++++++++++++++
.../management/ActiveMQServerControlTest.java | 6 +
36 files changed, 2312 insertions(+), 514 deletions(-)
create mode 100644
artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/BrokerConnectionControl.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationAddressPolicyControl.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationConsumer.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/{federation/FederationConsumerInfo.java
=> connect/federation/AMQPFederationConsumerControl.java} (66%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationConsumerControlType.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationManagementSupport.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/{federation/Federation.java
=> connect/federation/AMQPFederationPolicyControl.java} (50%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationQueuePolicyControl.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/{Federation.java
=> FederationReceiveFromResourcePolicy.java} (54%)
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/{Federation.java
=> FederationType.java} (64%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/internal/FederationPolicyManager.java
create mode 100644
artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/BrokerConnectionControlImpl.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPFederationManagementTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
