From 21391ceab4d9228e7ce700899d77ae68955d2eaa Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Tue, 23 Jan 2007 22:38:12 +0000
Subject: [PATCH] add synchronize around add() - see
 http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8550623

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499169 13f79535-47bb-0310-9956-ffa450edef68
---
 .../apache/activemq/broker/region/DurableTopicSubscription.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
index 89cb524e82..35a67f608a 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
@@ -57,7 +57,7 @@ public class DurableTopicSubscription extends PrefetchSubscription {
     synchronized public void gc() {
     }
 
-    public void add(ConnectionContext context, Destination destination) throws Exception {
+    public synchronized void add(ConnectionContext context, Destination destination) throws Exception {
         super.add(context, destination);
         destinations.put(destination.getActiveMQDestination(), destination);
         if( active || keepDurableSubsActive ) {