You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2008/04/16 16:34:05 UTC
svn commit: r648708 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java
Author: rajdavies
Date: Wed Apr 16 07:34:03 2008
New Revision: 648708
URL: http://svn.apache.org/viewvc?rev=648708&view=rev
Log:
extra synchronization
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java?rev=648708&r1=648707&r2=648708&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java Wed Apr 16 07:34:03 2008
@@ -105,7 +105,7 @@
}
}
- public SubscriptionInfo lookupSubscription(String clientId, String subscriptionName) throws IOException {
+ public synchronized SubscriptionInfo lookupSubscription(String clientId, String subscriptionName) throws IOException {
return subscriberContainer.get(getSubscriptionKey(clientId, subscriptionName));
}
@@ -133,7 +133,7 @@
removeSubscriberMessageContainer(key);
}
- public void recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
+ public synchronized void recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
throws Exception {
String key = getSubscriptionKey(clientId, subscriptionName);
TopicSubContainer container = subscriberMessages.get(key);
@@ -150,7 +150,7 @@
}
}
- public void recoverNextMessages(String clientId, String subscriptionName, int maxReturned,
+ public synchronized void recoverNextMessages(String clientId, String subscriptionName, int maxReturned,
MessageRecoveryListener listener) throws Exception {
String key = getSubscriptionKey(clientId, subscriptionName);
TopicSubContainer container = subscriberMessages.get(key);
@@ -183,7 +183,7 @@
}
}
- public void delete() {
+ public synchronized void delete() {
super.delete();
ackContainer.clear();
subscriberContainer.clear();
@@ -210,7 +210,7 @@
return container;
}
- protected void removeSubscriberMessageContainer(Object key)
+ protected synchronized void removeSubscriberMessageContainer(Object key)
throws IOException {
subscriberContainer.remove(key);
TopicSubContainer container = subscriberMessages.remove(key);
@@ -235,7 +235,7 @@
}
- public int getMessageCount(String clientId, String subscriberName) throws IOException {
+ public synchronized int getMessageCount(String clientId, String subscriberName) throws IOException {
String key = getSubscriptionKey(clientId, subscriberName);
TopicSubContainer container = subscriberMessages.get(key);
return container != null ? container.size() : 0;