You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/03/06 16:33:45 UTC
svn commit: r383565 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
Author: jstrachan
Date: Mon Mar 6 07:33:43 2006
New Revision: 383565
URL: http://svn.apache.org/viewcvs?rev=383565&view=rev
Log:
added better exception message
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?rev=383565&r1=383564&r2=383565&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java Mon Mar 6 07:33:43 2006
@@ -66,12 +66,14 @@
lookup(context, destination);
}
- SubscriptionKey key = new SubscriptionKey(context.getClientId(), info.getSubcriptionName());
+ String clientId = context.getClientId();
+ String subcriptionName = info.getSubcriptionName();
+ SubscriptionKey key = new SubscriptionKey(clientId, subcriptionName);
DurableTopicSubscription sub = (DurableTopicSubscription) durableSubscriptions.get(key);
if (sub != null) {
if (sub.isActive()) {
- throw new JMSException("Durable consumer is in use");
+ throw new JMSException("Durable consumer is in use for client: " + clientId + " and subscriptionName: " + subcriptionName);
}
// Has the selector changed??