This is an automated email from the ASF dual-hosted git repository.
tabish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new a2647113f7 ARTEMIS-5651 Add missing synchronized tag to some brifge
methods
a2647113f7 is described below
commit a2647113f78e8272f87a3cbc149021c79e4ae104
Author: Timothy Bish <[email protected]>
AuthorDate: Tue Sep 9 15:24:32 2025 -0400
ARTEMIS-5651 Add missing synchronized tag to some brifge methods
Add synchronized tags to methods in the AMQP bridge from and to queue
policy managers
---
.../amqp/connect/bridge/AMQPBridgeFromQueuePolicyManager.java | 2 +-
.../amqp/connect/bridge/AMQPBridgeToQueuePolicyManager.java | 6 +++---
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeFromQueuePolicyManager.java
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeFromQueuePolicyManager.java
index 07db73f6cc..d89e94f9f4 100644
---
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeFromQueuePolicyManager.java
+++
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeFromQueuePolicyManager.java
@@ -124,7 +124,7 @@ public final class AMQPBridgeFromQueuePolicyManager extends
AMQPBridgeFromPolicy
}
@Override
- public void afterAddBinding(Binding binding) throws ActiveMQException {
+ public synchronized void afterAddBinding(Binding binding) throws
ActiveMQException {
if (isActive() && configuration.isReceiverDemandTrackingDisabled() &&
binding instanceof QueueBinding queueBinding) {
reactIfQueueMatchesPolicy(queueBinding.getQueue());
}
diff --git
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToQueuePolicyManager.java
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToQueuePolicyManager.java
index 8bdc2352e3..bd23d8ca18 100644
---
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToQueuePolicyManager.java
+++
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/bridge/AMQPBridgeToQueuePolicyManager.java
@@ -82,15 +82,15 @@ public class AMQPBridgeToQueuePolicyManager extends
AMQPBridgeToPolicyManager im
}
@Override
- public void afterCreateQueue(Queue queue) throws ActiveMQException {
+ public synchronized void afterCreateQueue(Queue queue) throws
ActiveMQException {
if (isActive()) {
checkQueueForMatch(queue);
}
}
@Override
- public void afterDestroyQueue(Queue queue, SimpleString address, final
SecurityAuth session, boolean checkConsumerCount,
- boolean removeConsumers, boolean
autoDeleteAddress) throws ActiveMQException {
+ public synchronized void afterDestroyQueue(Queue queue, SimpleString
address, final SecurityAuth session, boolean checkConsumerCount,
+ boolean removeConsumers, boolean
autoDeleteAddress) throws ActiveMQException {
if (isActive()) {
final String fqqn =
CompositeAddress.toFullyQualified(queue.getAddress(),
queue.getName()).toString();
final AMQPBridgeQueueSenderManager manager =
queueSenders.remove(fqqn);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
