Java 类com.hazelcast.core.MemberAttributeEvent 实例源码

项目:reactive-data    文件:AbstractMembershipEventObserver.java   
@Override
public final void update(Observable arg0, Object arg1) {

  if(arg1 instanceof MembershipEvent)
  {

    MembershipEvent me = (MembershipEvent) arg1;
    switch(me.getEventType())
    {
      case MembershipEvent.MEMBER_ADDED:
        handleMemberAdded(me.getMember());
        break;
      case MembershipEvent.MEMBER_REMOVED:
        handleMemberRemoved(me.getMember());
        break;
      case MembershipEvent.MEMBER_ATTRIBUTE_CHANGED:
        MemberAttributeEvent ma = (MemberAttributeEvent) arg1;
        handleMemberModified(ma.getMember(), ma.getOperationType());
        break;
        default: break;
    }
  }

}
项目:bagri    文件:SchemaManagement.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    logger.trace("memberAttributeChanged.enter; event: {}; attribute: {}; value: {}", 
            memberAttributeEvent, memberAttributeEvent.getKey(), memberAttributeEvent.getValue());
    // if attribute is schemas then deploy schema on member ?
    if (pn_cluster_node_schemas.equals(memberAttributeEvent.getKey())) {
        Member member = memberAttributeEvent.getMember();
        String nodeName = member.getStringAttribute(pn_cluster_node_name);
        if (memberAttributeEvent.getOperationType() == MemberAttributeOperationType.PUT) {
            // set
            String newSchemas = (String) memberAttributeEvent.getValue();
            // do this via memberAdded??
        } else {
            // remove all
        }
    }
}
项目:mesos-artifacts    文件:MesosMembershipScheme.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    if (log.isDebugEnabled()) {
        log.debug(String.format("Member attribute changed: [Key] %s, [Value] %s", memberAttributeEvent.getKey(),
                memberAttributeEvent.getValue()));
    }
}
项目:ravikumaran201504    文件:HazelcastClusterStore.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    log.info("Member {} attribute {} changed to {}",
             memberAttributeEvent.getMember(),
             memberAttributeEvent.getKey(),
             memberAttributeEvent.getValue());
}
项目:sctalk    文件:MyClusterMembershipListener.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    // TODO Auto-generated method stub

}
项目:apgas    文件:Transport.java   
@Override
synchronized public void memberAttributeChanged(
    MemberAttributeEvent memberAttributeEvent) {
  // unused
}
项目:reactive-data    文件:InstanceListener.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent event) {
  setChanged();
   notifyObservers(event);
}
项目:Camel    文件:HazelcastInstanceConsumer.java   
public void memberAttributeChanged(MemberAttributeEvent event) {
    this.sendExchange(event, HazelcastConstants.UPDATED);
}
项目:spike.x    文件:HzEventListener.java   
@Override
public void memberAttributeChanged(final MemberAttributeEvent event) {
    m_logger.debug("Member attribute changed: {} {}",
            event.getMember().getSocketAddress(),
            event.getMember().getUuid());
}
项目:bagri    文件:TopologyManagement.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    // nothing to do here
}
项目:bagri    文件:AccessManagementBridge.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    // no-op
}
项目:bagri    文件:PopulationManagementImpl.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    logger.trace("memberAttributeChaged; event: {}", memberAttributeEvent);
}
项目:Openfire    文件:ClusterListener.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent event) {
    ClusterNodeInfo priorNodeInfo = clusterNodesInfo.get(event.getMember().getUuid());
    clusterNodesInfo.put(event.getMember().getUuid(), 
            new HazelcastClusterNodeInfo(event.getMember(), priorNodeInfo.getJoinedTime()));
}
项目:carbon-business-process    文件:BPELServerImpl.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    // Noting to do here.
}
项目:jcconf2014-hazelcast-sample    文件:CloudNodeImpl.java   
/**
 * {@inheritDoc}
 */
@Override
public void memberAttributeChanged(final MemberAttributeEvent memberAttributeEvent) {
    // Do nothing.
}
项目:andes    文件:HazelcastCoordinationStrategy.java   
/**
 * {@inheritDoc}
 */
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    // do nothing here, since member attributes are not used in the implementation
}
项目:andes    文件:HazelcastBasedNetworkPartitionDetector.java   
/**
 * {@inheritDoc}
 */
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
    // Do nothing
}
项目:vertx-hazelcast    文件:HazelcastClusterManager.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
}
项目:vertigo    文件:HazelcastClusterListener.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent event) {
  // Do nothing.
}
项目:CSX278    文件:HazelcastTransport.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {

}
项目:DSC    文件:ControllerMembershipListener.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent arg0) {

}
项目:lumongo    文件:HazelcastManager.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {

}
项目:gw2live    文件:ClusterListener.java   
@Override
public void memberAttributeChanged(MemberAttributeEvent mae) {

}