private void indicationOccured(String url,CIMInstance indication,boolean wasQueued){
  if (wasQueued) {
    s_logger.debug("{} Dequeued: {}",new Object[]{url,indication.toString()});
  }
 else {
    s_logger.debug("{} Received: {}",new Object[]{url,indication.toString()});
  }
  Runnable indicationWorker=new IndicationWorkerThread(url,indication,wasQueued);
  executorService.execute(indicationWorker);
}

private void indicationOccured ( String url , CIMInstance indication , boolean wasQueued ) { if ( wasQueued ) { s_logger . debug ( "{} Dequeued: {}" , new Object [ ] { url , indication . toString ( ) } ) ; } else { s_logger . debug ( "{} Received: {}" , new Object [ ] { url , indication . toString ( ) } ) ; } Runnable indicationWorker = new IndicationWorkerThread ( url , indication , wasQueued ) ; executorService . execute ( indicationWorker ) ; }
forwards cim indications to a matching connection . this only works if the connection put its connection name in its destination url when it subscribed . an indication that has no matching connection is discarded . when the listener is paused , indications are queued .
