From 00ee9491d9e21b85f44f23e05bc1bd6fd82dc2cc Mon Sep 17 00:00:00 2001 From: gtully Date: Mon, 29 May 2017 11:21:00 +0100 Subject: [PATCH] [AMQ-6678] sync destructive purge on queue view mbean (jmx) to prevent concurrent calls --- .../src/main/java/org/apache/activemq/broker/jmx/QueueView.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/QueueView.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/QueueView.java index 528e10c262..372bb80283 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/QueueView.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/QueueView.java @@ -56,7 +56,7 @@ public class QueueView extends DestinationView implements QueueViewMBean { return result; } - public void purge() throws Exception { + public synchronized void purge() throws Exception { final long originalMessageCount = destination.getDestinationStatistics().getMessages().getCount(); ((Queue)destination).purge();