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 f860be432e NO-JIRA small doc fix for HTTP
add d830f04de8 ARTEMIS-4419 Add federation support to AMQP broker
connections
No new revisions were added by this update.
Summary of changes:
.../core/config/FederationConfiguration.java | 5 +-
.../protocol/amqp/broker/AMQPSessionCallback.java | 53 +-
.../amqp/connect/AMQPBrokerConnection.java | 196 +-
.../amqp/connect/AMQPBrokerConnectionManager.java | 11 +-
.../amqp/connect/federation/AMQPFederation.java | 327 +++
.../federation/AMQPFederationAddressConsumer.java | 497 ++++
.../AMQPFederationAddressPolicyManager.java | 217 ++
.../AMQPFederationAddressSenderController.java | 213 ++
.../AMQPFederationCommandDispatcher.java | 137 ++
.../federation/AMQPFederationCommandProcessor.java | 162 ++
.../federation/AMQPFederationConfiguration.java | 135 ++
.../federation/AMQPFederationConstants.java | 200 ++
.../AMQPFederationConsumerConfiguration.java | 94 +
.../federation/AMQPFederationPolicySupport.java | 535 ++++
.../federation/AMQPFederationQueueConsumer.java | 556 +++++
.../AMQPFederationQueuePolicyManager.java | 135 ++
.../AMQPFederationQueueSenderController.java | 166 ++
.../connect/federation/AMQPFederationSource.java | 422 ++++
.../connect/federation/AMQPFederationTarget.java | 150 ++
.../ActiveMQServerAMQPFederationPlugin.java | 181 ++
.../connect/mirror/AMQPMirrorControllerTarget.java | 4 +-
.../Federation.java} | 32 +-
.../FederationConstants.java} | 22 +-
.../amqp/federation/FederationConsumer.java | 19 +-
.../amqp/federation/FederationConsumerInfo.java | 105 +
.../FederationReceiveFromAddressPolicy.java | 182 ++
.../FederationReceiveFromQueuePolicy.java | 148 ++
.../internal/FederationAddressPolicyManager.java | 487 ++++
.../internal/FederationConsumerEntry.java | 71 +
.../internal/FederationConsumerInternal.java | 56 +
.../internal/FederationGenericConsumerInfo.java | 184 ++
.../internal/FederationInternal.java} | 32 +-
.../internal/FederationQueuePolicyManager.java | 336 +++
.../logger/ActiveMQAMQPProtocolMessageBundle.java | 7 +
.../amqp/proton/AMQPConnectionContext.java | 186 +-
.../protocol/amqp/proton/AMQPSessionContext.java | 123 +-
.../artemis/protocol/amqp/proton/AmqpSupport.java | 99 +
.../amqp/proton/ProtonAbstractReceiver.java | 98 +-
.../protocol/amqp/proton/ProtonInitializable.java | 12 +-
.../amqp/proton/ProtonServerReceiverContext.java | 12 +-
.../amqp/proton/ProtonServerSenderContext.java | 25 +-
.../amqp/proton/handler/ProtonHandler.java | 5 +
.../AMQPFederationPolicySupportTest.java | 712 ++++++
.../protocol/amqp/proton/AmqpSupportTest.java | 111 +
.../artemis/core/config/Configuration.java | 6 +
.../AMQPBrokerConnectConfiguration.java | 14 +-
.../AMQPBrokerConnectionAddressType.java | 2 +-
.../AMQPFederatedBrokerConnectionElement.java | 166 ++
.../AMQPFederationAddressPolicyElement.java | 252 ++
.../AMQPFederationBrokerPlugin.java | 19 +-
.../AMQPFederationQueuePolicyElement.java | 231 ++
.../core/config/impl/ConfigurationImpl.java | 24 +-
.../deployers/impl/FileConfigurationParser.java | 121 +-
.../artemis/core/server/ActiveMQServer.java | 7 +
.../core/server/impl/ActiveMQServerImpl.java | 16 +
.../resources/schema/artemis-configuration.xsd | 97 +
.../core/config/impl/ConfigurationImplTest.java | 254 ++
.../resources/ConfigurationTest-full-config.xml | 40 +
docs/user-manual/amqp-broker-connections.adoc | 106 +
.../broker-connection/amqp-federation/pom.xml | 164 ++
.../broker-connection/amqp-federation/readme.md | 5 +
.../jms/example/BrokerFederationExample.java | 77 +
.../src/main/resources/activemq/server0/broker.xml | 123 +
.../src/main/resources/activemq/server1/broker.xml | 106 +
examples/features/broker-connection/pom.xml | 2 +
pom.xml | 13 +
tests/integration-tests/pom.xml | 6 +-
.../connect/AMQPFederationAddressPolicyTest.java | 2166 +++++++++++++++++
.../connect/AMQPFederationBrokerPliuginTest.java | 565 +++++
.../amqp/connect/AMQPFederationConnectTest.java | 520 ++++
.../connect/AMQPFederationQueuePolicyTest.java | 2544 ++++++++++++++++++++
.../connect/AMQPFederationServerToServerTest.java | 484 ++++
.../amqp/connect/AMQPMirrorConnectionTest.java | 266 ++
tests/smoke-tests/pom.xml | 35 +
.../servers/brokerConnect/federationA/broker.xml | 195 ++
.../servers/brokerConnect/federationB/broker.xml | 196 ++
.../smoke/brokerConnection/DualFederationTest.java | 117 +
.../config/impl/ConfigurationValidationTest.java | 101 +-
78 files changed, 16239 insertions(+), 261 deletions(-)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederation.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationAddressConsumer.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationAddressPolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationAddressSenderController.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationCommandDispatcher.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationCommandProcessor.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationConfiguration.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationConstants.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationConsumerConfiguration.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationPolicySupport.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationQueueConsumer.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationQueuePolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationQueueSenderController.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationSource.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationTarget.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/ActiveMQServerAMQPFederationPlugin.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/{proton/ProtonInitializable.java
=> federation/Federation.java} (58%)
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/{proton/ProtonInitializable.java
=> federation/FederationConstants.java} (63%)
copy
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/amqpBrokerConnectivity/AMQPBrokerConnectionAddressType.java
=>
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/FederationConsumer.java
(62%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/FederationConsumerInfo.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/FederationReceiveFromAddressPolicy.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/FederationReceiveFromQueuePolicy.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/internal/FederationAddressPolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/internal/FederationConsumerEntry.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/internal/FederationConsumerInternal.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/internal/FederationGenericConsumerInfo.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/{proton/ProtonInitializable.java
=> federation/internal/FederationInternal.java} (52%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/federation/internal/FederationQueuePolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/test/java/org/apache/activemq/artemis/protocol/amqp/connect/federation/AMQPFederationPolicySupportTest.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/test/java/org/apache/activemq/artemis/protocol/amqp/proton/AmqpSupportTest.java
create mode 100644
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/amqpBrokerConnectivity/AMQPFederatedBrokerConnectionElement.java
create mode 100644
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/amqpBrokerConnectivity/AMQPFederationAddressPolicyElement.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonInitializable.java
=>
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/amqpBrokerConnectivity/AMQPFederationBrokerPlugin.java
(63%)
create mode 100644
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/amqpBrokerConnectivity/AMQPFederationQueuePolicyElement.java
create mode 100644 examples/features/broker-connection/amqp-federation/pom.xml
create mode 100644
examples/features/broker-connection/amqp-federation/readme.md
create mode 100644
examples/features/broker-connection/amqp-federation/src/main/java/org/apache/activemq/artemis/jms/example/BrokerFederationExample.java
create mode 100644
examples/features/broker-connection/amqp-federation/src/main/resources/activemq/server0/broker.xml
create mode 100644
examples/features/broker-connection/amqp-federation/src/main/resources/activemq/server1/broker.xml
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPFederationAddressPolicyTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPFederationBrokerPliuginTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPFederationConnectTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPFederationQueuePolicyTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPFederationServerToServerTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPMirrorConnectionTest.java
create mode 100644
tests/smoke-tests/src/main/resources/servers/brokerConnect/federationA/broker.xml
create mode 100644
tests/smoke-tests/src/main/resources/servers/brokerConnect/federationB/broker.xml
create mode 100644
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualFederationTest.java
