org.elasticsearch.discovery.jgroups
Class JgroupsDiscovery

java.lang.Object
  extended by org.elasticsearch.util.component.AbstractComponent
      extended by org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
          extended by org.elasticsearch.discovery.jgroups.JgroupsDiscovery
All Implemented Interfaces:
org.elasticsearch.discovery.Discovery, org.elasticsearch.util.component.CloseableComponent, org.elasticsearch.util.component.LifecycleComponent<org.elasticsearch.discovery.Discovery>, org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver

public class JgroupsDiscovery
extends org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
implements org.elasticsearch.discovery.Discovery, org.jgroups.Receiver


Field Summary
 
Fields inherited from class org.elasticsearch.util.component.AbstractLifecycleComponent
lifecycle
 
Fields inherited from class org.elasticsearch.util.component.AbstractComponent
componentSettings, logger, settings
 
Constructor Summary
JgroupsDiscovery(org.elasticsearch.util.settings.Settings settings, org.elasticsearch.env.Environment environment, org.elasticsearch.cluster.ClusterName clusterName, org.elasticsearch.transport.TransportService transportService, org.elasticsearch.cluster.ClusterService clusterService, org.elasticsearch.util.network.NetworkService networkService)
           
 
Method Summary
 void addListener(org.elasticsearch.discovery.InitialStateDiscoveryListener listener)
           
 void block()
           
protected  void doClose()
           
protected  void doStart()
           
protected  void doStop()
           
 boolean firstMaster()
           
 byte[] getState()
           
 java.lang.String nodeDescription()
           
 void publish(org.elasticsearch.cluster.ClusterState clusterState)
           
 void receive(org.jgroups.Message msg)
           
 void removeListener(org.elasticsearch.discovery.InitialStateDiscoveryListener listener)
           
 void setState(byte[] state)
           
 void suspect(org.jgroups.Address suspectedMember)
           
 void viewAccepted(org.jgroups.View newView)
           
 
Methods inherited from class org.elasticsearch.util.component.AbstractLifecycleComponent
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
 
Methods inherited from class org.elasticsearch.util.component.AbstractComponent
nodeName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.elasticsearch.util.component.LifecycleComponent
addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop
 
Methods inherited from interface org.elasticsearch.util.component.CloseableComponent
close
 

Constructor Detail

JgroupsDiscovery

@Inject
public JgroupsDiscovery(org.elasticsearch.util.settings.Settings settings,
                               org.elasticsearch.env.Environment environment,
                               org.elasticsearch.cluster.ClusterName clusterName,
                               org.elasticsearch.transport.TransportService transportService,
                               org.elasticsearch.cluster.ClusterService clusterService,
                               org.elasticsearch.util.network.NetworkService networkService)
Method Detail

addListener

public void addListener(org.elasticsearch.discovery.InitialStateDiscoveryListener listener)
Specified by:
addListener in interface org.elasticsearch.discovery.Discovery

removeListener

public void removeListener(org.elasticsearch.discovery.InitialStateDiscoveryListener listener)
Specified by:
removeListener in interface org.elasticsearch.discovery.Discovery

doStart

protected void doStart()
                throws org.elasticsearch.ElasticSearchException
Specified by:
doStart in class org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
Throws:
org.elasticsearch.ElasticSearchException

doStop

protected void doStop()
               throws org.elasticsearch.ElasticSearchException
Specified by:
doStop in class org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
Throws:
org.elasticsearch.ElasticSearchException

doClose

protected void doClose()
                throws org.elasticsearch.ElasticSearchException
Specified by:
doClose in class org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
Throws:
org.elasticsearch.ElasticSearchException

nodeDescription

public java.lang.String nodeDescription()
Specified by:
nodeDescription in interface org.elasticsearch.discovery.Discovery

firstMaster

public boolean firstMaster()
Specified by:
firstMaster in interface org.elasticsearch.discovery.Discovery

publish

public void publish(org.elasticsearch.cluster.ClusterState clusterState)
Specified by:
publish in interface org.elasticsearch.discovery.Discovery

receive

public void receive(org.jgroups.Message msg)
Specified by:
receive in interface org.jgroups.MessageListener

getState

public byte[] getState()
Specified by:
getState in interface org.jgroups.MessageListener

setState

public void setState(byte[] state)
Specified by:
setState in interface org.jgroups.MessageListener

viewAccepted

public void viewAccepted(org.jgroups.View newView)
Specified by:
viewAccepted in interface org.jgroups.MembershipListener

suspect

public void suspect(org.jgroups.Address suspectedMember)
Specified by:
suspect in interface org.jgroups.MembershipListener

block

public void block()
Specified by:
block in interface org.jgroups.MembershipListener