NotificationHubClient.java 文件源码

/**
 * send the notification to actual client on the Managing node VM
 * 
 * it does not throw any exception. it will capture all exception and log a warning
 * 
 * @param event
 */
public void sendNotification(EntryEvent<NotificationKey, Notification> event) {

  NotificationBroadCasterProxy notifBroadCaster;
  try {

    notifBroadCaster = proxyFactory.findProxy(event.getKey().getObjectName(),
        NotificationBroadCasterProxy.class);
    // Will return null if the Bean is filtered out.
    if (notifBroadCaster != null) {
      notifBroadCaster.sendNotification(event.getNewValue());
    }

  } catch (Exception e) {
    if (logger.isDebugEnabled()) {
      logger.debug(" NOTIFICATION Not Done {}", e.getMessage(), e);
    }
    logger.warn(e.getMessage(), e);
  }

}