if (log.isInfoEnabled()) {
log.info(String.format("Removed Service{uri=%s}", uri));
}
if (discoveryListener != null) {
final DiscoveryListener discoveryListener = this.discoveryListener;
// Have the listener process the event async so that
// he does not block this thread since we are doing time sensitive
// processing of events.
executor.execute(new Runnable() {
public void run() {
if (discoveryListener != null) {
discoveryListener.serviceRemoved(uri);
}
}
});
}
}