mirror of https://github.com/apache/activemq.git
Notify the listener after the destination collections are updated; as a listener might look at the collections :)
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@681153 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
ecfae00e3c
commit
3a77300e06
|
@ -143,10 +143,6 @@ public class DestinationSource implements MessageListener {
|
||||||
}
|
}
|
||||||
|
|
||||||
protected void fireDestinationEvent(DestinationEvent event) {
|
protected void fireDestinationEvent(DestinationEvent event) {
|
||||||
if (listener != null) {
|
|
||||||
listener.onDestinationEvent(event);
|
|
||||||
}
|
|
||||||
|
|
||||||
// now lets update the data structures
|
// now lets update the data structures
|
||||||
ActiveMQDestination destination = event.getDestination();
|
ActiveMQDestination destination = event.getDestination();
|
||||||
boolean add = event.isAddOperation();
|
boolean add = event.isAddOperation();
|
||||||
|
@ -189,5 +185,8 @@ public class DestinationSource implements MessageListener {
|
||||||
else {
|
else {
|
||||||
LOG.warn("Unknown destination type: " + destination);
|
LOG.warn("Unknown destination type: " + destination);
|
||||||
}
|
}
|
||||||
|
if (listener != null) {
|
||||||
|
listener.onDestinationEvent(event);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue