mirror of https://github.com/apache/activemq.git
accounts for nested Destination filters. git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1489485 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
ba37cbb1de
commit
8a524d52ef
|
@ -389,8 +389,13 @@ public class DestinationFilter implements Destination {
|
|||
}
|
||||
|
||||
public void deleteSubscription(ConnectionContext context, SubscriptionKey key) throws Exception {
|
||||
if (next instanceof Topic) {
|
||||
((Topic) next).deleteSubscription(context, key);
|
||||
Destination target = next;
|
||||
while (target instanceof DestinationFilter) {
|
||||
target = ((DestinationFilter) target).next;
|
||||
}
|
||||
if (target instanceof Topic) {
|
||||
Topic topic = (Topic)target;
|
||||
topic.deleteSubscription(context, key);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue