mirror of https://github.com/apache/activemq.git
This closes #86
commit 72837960cf
Author: Christopher L. Shannon (cshannon)
<christopher.l.shannon@gmail.com>
Updated durable related error messages in TopicRegion to include both
subscriptionName and clientId.
This commit is contained in:
parent
a5a52b6517
commit
be66175079
|
@ -200,7 +200,9 @@ public class TopicRegion extends AbstractRegion {
|
|||
SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
|
||||
DurableTopicSubscription sub = durableSubscriptions.get(key);
|
||||
if (sub == null) {
|
||||
throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
|
||||
throw new InvalidDestinationException("No durable subscription exists for clientID: " +
|
||||
info.getClientId() + " and subscriptionName: " +
|
||||
info.getSubscriptionName());
|
||||
}
|
||||
if (sub.isActive()) {
|
||||
throw new JMSException("Durable consumer is in use");
|
||||
|
@ -336,7 +338,9 @@ public class TopicRegion extends AbstractRegion {
|
|||
}
|
||||
durableSubscriptions.put(key, sub);
|
||||
} else {
|
||||
throw new JMSException("That durable subscription is already active.");
|
||||
throw new JMSException("Durable subscription is already active for clientID: " +
|
||||
context.getClientId() + " and subscriptionName: " +
|
||||
info.getSubscriptionName());
|
||||
}
|
||||
return sub;
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue