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 900e329c90 ARTEMIS-5441 Flow control on PageTimedWriter deadlocks with
Repliation.start
add 455c020465 ARTEMIS-5437 Add a bridging feature to AMQP broker
connections
No new revisions were added by this update.
Summary of changes:
.../amqp/connect/AMQPBrokerConnection.java | 67 +-
.../amqp/connect/AMQPBrokerConnectionManager.java | 1 -
.../bridge/AMQPBridgeAddressPolicy.java} | 116 +-
.../AMQPBridgeAsyncCompletion.java} | 19 +-
.../connect/bridge/AMQPBridgeConfiguration.java | 317 ++
.../amqp/connect/bridge/AMQPBridgeConstants.java | 253 ++
.../bridge/AMQPBridgeFromAddressPolicyManager.java | 445 +++
.../bridge/AMQPBridgeFromAddressReceiver.java | 331 ++
.../bridge/AMQPBridgeFromPolicyManager.java | 129 +
.../bridge/AMQPBridgeFromQueuePolicyManager.java | 314 ++
.../AMQPBridgeFromQueueReceiver.java} | 212 +-
.../bridge/AMQPBridgeLinkConfiguration.java | 144 +
.../bridge/AMQPBridgeManagementSupport.java | 371 ++
.../amqp/connect/bridge/AMQPBridgeManager.java | 375 ++
.../AMQPBridgeManagerControl.java} | 18 +-
.../AMQPBridgeManagerControlType.java} | 34 +-
.../amqp/connect/bridge/AMQPBridgeManagers.java | 153 +
.../AMQPBridgeMetrics.java} | 62 +-
.../amqp/connect/bridge/AMQPBridgePolicy.java | 106 +
.../connect/bridge/AMQPBridgePolicyManager.java | 254 ++
.../AMQPBridgePolicyManagerControl.java} | 24 +-
.../AMQPBridgePolicyManagerControlType.java} | 35 +-
.../bridge/AMQPBridgeQueuePolicy.java} | 77 +-
.../amqp/connect/bridge/AMQPBridgeReceiver.java | 414 +++
.../bridge/AMQPBridgeReceiverConfiguration.java | 198 +
.../connect/bridge/AMQPBridgeReceiverControl.java | 107 +
.../AMQPBridgeReceiverControlType.java} | 58 +-
.../connect/bridge/AMQPBridgeReceiverInfo.java | 170 +
.../connect/bridge/AMQPBridgeReceiverManager.java | 544 +++
.../amqp/connect/bridge/AMQPBridgeSender.java | 239 ++
.../bridge/AMQPBridgeSenderConfiguration.java | 25 +-
.../connect/bridge/AMQPBridgeSenderControl.java | 106 +
.../AMQPBridgeSenderControlType.java} | 16 +-
.../amqp/connect/bridge/AMQPBridgeSenderInfo.java | 144 +
.../connect/bridge/AMQPBridgeSenderManager.java | 290 ++
.../amqp/connect/bridge/AMQPBridgeSupport.java | 246 ++
.../bridge/AMQPBridgeToAddressPolicyManager.java | 183 +
.../connect/bridge/AMQPBridgeToAddressSender.java | 269 ++
.../connect/bridge/AMQPBridgeToPolicyManager.java | 104 +
.../bridge/AMQPBridgeToQueuePolicyManager.java | 177 +
.../connect/bridge/AMQPBridgeToQueueSender.java | 247 ++
.../AMQPBridgeToSenderController.java} | 135 +-
.../bridge/AMQPBridgeType.java} | 26 +-
.../federation/AMQPFederationAddressConsumer.java | 30 +-
.../federation/AMQPFederationQueueConsumer.java | 34 +-
.../connect/mirror/AMQPMirrorControllerTarget.java | 36 +-
.../amqp/proton/AMQPConnectionContext.java | 9 -
.../protocol/amqp/proton/AMQPSessionContext.java | 6 -
.../artemis/protocol/amqp/proton/AmqpSupport.java | 7 +-
.../amqp/proton/DefaultSenderController.java | 30 +-
.../amqp/proton/ProtonAbstractReceiver.java | 33 +-
.../amqp/proton/ProtonServerReceiverContext.java | 21 +-
.../amqp/proton/ProtonServerSenderContext.java | 8 +-
...nt.java => AMQPBridgeAddressPolicyElement.java} | 135 +-
.../AMQPBridgeBrokerConnectionElement.java | 198 +
...ment.java => AMQPBridgeQueuePolicyElement.java} | 127 +-
.../AMQPBrokerConnectConfiguration.java | 11 +
.../AMQPBrokerConnectionAddressType.java | 2 +-
.../deployers/impl/FileConfigurationParser.java | 163 +-
.../artemis/core/server/ActiveMQServerLogger.java | 4 +
.../resources/schema/artemis-configuration.xsd | 189 +
.../core/config/impl/ConfigurationImplTest.java | 242 ++
.../config/impl/ConfigurationValidationTest.java | 71 +-
.../resources/ConfigurationTest-full-config.xml | 33 +
docs/user-manual/amqp-broker-connections.adoc | 129 +-
.../amqp/AmqpCoreTunnelingSupportTest.java | 230 ++
.../connect/AMQPBridgeConfigurationReloadTest.java | 416 +++
.../amqp/connect/AMQPBridgeFromAddressTest.java | 3554 ++++++++++++++++++
.../amqp/connect/AMQPBridgeFromQueueTest.java | 3791 ++++++++++++++++++++
.../amqp/connect/AMQPBridgeManagementTest.java | 1500 ++++++++
.../amqp/connect/AMQPBridgeServerToServerTest.java | 912 +++++
.../amqp/connect/AMQPBridgeToAddressTest.java | 1120 ++++++
.../amqp/connect/AMQPBridgeToQueueTest.java | 1326 +++++++
.../connect/AMQPBrokerConnectionReceiverTest.java | 24 +-
.../connect/AMQPFederationAddressPolicyTest.java | 72 +-
.../connect/AMQPFederationQueuePolicyTest.java | 72 +
76 files changed, 21393 insertions(+), 697 deletions(-)
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/{federation/FederationReceiveFromAddressPolicy.java
=> connect/bridge/AMQPBridgeAddressPolicy.java} (52%)
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationAsyncCompletion.java
=> bridge/AMQPBridgeAsyncCompletion.java} (65%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeConfiguration.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeConstants.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeFromAddressPolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeFromAddressReceiver.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeFromPolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeFromQueuePolicyManager.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationQueueConsumer.java
=> bridge/AMQPBridgeFromQueueReceiver.java} (61%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeLinkConfiguration.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeManagementSupport.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeManager.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationControl.java
=> bridge/AMQPBridgeManagerControl.java} (58%)
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationSourceControlType.java
=> bridge/AMQPBridgeManagerControlType.java} (61%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeManagers.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationMetrics.java
=> bridge/AMQPBridgeMetrics.java} (57%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgePolicy.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgePolicyManager.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationControl.java
=> bridge/AMQPBridgePolicyManagerControl.java} (51%)
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationLocalPolicyControlType.java
=> bridge/AMQPBridgePolicyManagerControlType.java} (63%)
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/{federation/FederationReceiveFromQueuePolicy.java
=> connect/bridge/AMQPBridgeQueuePolicy.java} (65%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeReceiver.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeReceiverConfiguration.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeReceiverControl.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationConsumerControlType.java
=> bridge/AMQPBridgeReceiverControlType.java} (61%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeReceiverInfo.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeReceiverManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeSender.java
copy
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/SensitiveDataCodec.java
=>
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeSenderConfiguration.java
(59%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeSenderControl.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationProducerControlType.java
=> bridge/AMQPBridgeSenderControlType.java} (85%)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeSenderInfo.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeSenderManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeSupport.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToAddressPolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToAddressSender.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToPolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToQueuePolicyManager.java
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToQueueSender.java
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/{federation/AMQPFederationSenderController.java
=> bridge/AMQPBridgeToSenderController.java} (72%)
copy
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/{federation/FederationType.java
=> connect/bridge/AMQPBridgeType.java} (58%)
copy
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/amqpBrokerConnectivity/{AMQPFederationAddressPolicyElement.java
=> AMQPBridgeAddressPolicyElement.java} (53%)
create mode 100644
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/amqpBrokerConnectivity/AMQPBridgeBrokerConnectionElement.java
copy
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/amqpBrokerConnectivity/{AMQPFederationQueuePolicyElement.java
=> AMQPBridgeQueuePolicyElement.java} (56%)
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpCoreTunnelingSupportTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeConfigurationReloadTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeFromAddressTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeFromQueueTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeManagementTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeServerToServerTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeToAddressTest.java
create mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeToQueueTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
