@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; } } }
@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 } } }
@Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { if (log.isDebugEnabled()) { log.debug(String.format("Member attribute changed: [Key] %s, [Value] %s", memberAttributeEvent.getKey(), memberAttributeEvent.getValue())); } }
@Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { log.info("Member {} attribute {} changed to {}", memberAttributeEvent.getMember(), memberAttributeEvent.getKey(), memberAttributeEvent.getValue()); }
@Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { // TODO Auto-generated method stub }
@Override synchronized public void memberAttributeChanged( MemberAttributeEvent memberAttributeEvent) { // unused }
@Override public void memberAttributeChanged(MemberAttributeEvent event) { setChanged(); notifyObservers(event); }
public void memberAttributeChanged(MemberAttributeEvent event) { this.sendExchange(event, HazelcastConstants.UPDATED); }
@Override public void memberAttributeChanged(final MemberAttributeEvent event) { m_logger.debug("Member attribute changed: {} {}", event.getMember().getSocketAddress(), event.getMember().getUuid()); }
@Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { // nothing to do here }
@Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { // no-op }
@Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { logger.trace("memberAttributeChaged; event: {}", memberAttributeEvent); }
@Override public void memberAttributeChanged(MemberAttributeEvent event) { ClusterNodeInfo priorNodeInfo = clusterNodesInfo.get(event.getMember().getUuid()); clusterNodesInfo.put(event.getMember().getUuid(), new HazelcastClusterNodeInfo(event.getMember(), priorNodeInfo.getJoinedTime())); }
@Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { // Noting to do here. }
/** * {@inheritDoc} */ @Override public void memberAttributeChanged(final MemberAttributeEvent memberAttributeEvent) { // Do nothing. }
/** * {@inheritDoc} */ @Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { // do nothing here, since member attributes are not used in the implementation }
/** * {@inheritDoc} */ @Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { // Do nothing }
@Override public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) { }
@Override public void memberAttributeChanged(MemberAttributeEvent event) { // Do nothing. }
@Override public void memberAttributeChanged(MemberAttributeEvent arg0) { }
@Override public void memberAttributeChanged(MemberAttributeEvent mae) { }