You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2017/05/29 10:21:18 UTC
activemq git commit: [AMQ-6678] sync destructive purge on queue view
mbean (jmx) to prevent concurrent calls
Repository: activemq
Updated Branches:
refs/heads/master 30d316298 -> 00ee9491d
[AMQ-6678] sync destructive purge on queue view mbean (jmx) to prevent concurrent calls
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/00ee9491
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/00ee9491
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/00ee9491
Branch: refs/heads/master
Commit: 00ee9491d9e21b85f44f23e05bc1bd6fd82dc2cc
Parents: 30d3162
Author: gtully <ga...@gmail.com>
Authored: Mon May 29 11:21:00 2017 +0100
Committer: gtully <ga...@gmail.com>
Committed: Mon May 29 11:21:00 2017 +0100
----------------------------------------------------------------------
.../src/main/java/org/apache/activemq/broker/jmx/QueueView.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/00ee9491/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/QueueView.java
----------------------------------------------------------------------
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 528e10c..372bb80 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();