Examples of com.linkedin.helix.HelixManager.addMessageListener()

com.linkedin.helix.HelixManager.addMessageListener()
@see MessageListener#onMessage(String,List,NotificationContext) @param listener @param instanceName

  
  for (String instance : curInstances.keySet()) {
    if (lastInstances == null || !lastInstances.containsKey(instance)) {
          try {
            // add message listeners for new sessions
            manager.addMessageListener(this, instance);
            LOG.info("Succeed in adding message listener for " + instance);
          }
          catch (Exception e)
          {
            LOG.error("Fail to add message listener for instance:" + instance, e);

View Full Code Here

      if (!_instanceSubscriptionNames.contains(instanceName))
      {
        try
        {
          logger.info("Adding message listener for " + instanceName);
          manager.addMessageListener(this, instanceName);
          _instanceSubscriptionNames.add(instanceName);
        }
        catch (Exception e)
        {
          logger.error("Exception adding message listener for instance:" + instanceName,

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.