Package org.elasticsearch.test.transport
Class StubbableConnectionManager
java.lang.Object
org.elasticsearch.test.transport.StubbableConnectionManager
- All Implemented Interfaces:
Closeable,AutoCloseable,ConnectionManager
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interfacestatic interfaceNested classes/interfaces inherited from interface org.elasticsearch.transport.ConnectionManager
ConnectionManager.ConnectionValidator, ConnectionManager.DelegatingNodeConnectionListener -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanaddGetConnectionBehavior(TransportAddress transportAddress, StubbableConnectionManager.GetConnectionBehavior connectBehavior) voidaddListener(TransportConnectionListener listener) voidclearBehavior(TransportAddress transportAddress) voidvoidclose()voidvoidconnectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, ActionListener<org.elasticsearch.core.Releasable> listener) voidgetConnection(DiscoveryNode node) booleannodeConnected(DiscoveryNode node) voidopenConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener) voidremoveListener(TransportConnectionListener listener) booleanbooleanintsize()
-
Constructor Details
-
StubbableConnectionManager
-
-
Method Details
-
addGetConnectionBehavior
public boolean addGetConnectionBehavior(TransportAddress transportAddress, StubbableConnectionManager.GetConnectionBehavior connectBehavior) -
setDefaultGetConnectionBehavior
public boolean setDefaultGetConnectionBehavior(StubbableConnectionManager.GetConnectionBehavior behavior) -
setDefaultNodeConnectedBehavior
public boolean setDefaultNodeConnectedBehavior(StubbableConnectionManager.NodeConnectedBehavior behavior) -
clearBehaviors
public void clearBehaviors() -
clearBehavior
-
openConnection
public void openConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener) - Specified by:
openConnectionin interfaceConnectionManager
-
getConnection
- Specified by:
getConnectionin interfaceConnectionManager
-
nodeConnected
- Specified by:
nodeConnectedin interfaceConnectionManager
-
addListener
- Specified by:
addListenerin interfaceConnectionManager
-
removeListener
- Specified by:
removeListenerin interfaceConnectionManager
-
connectToNode
public void connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, ActionListener<org.elasticsearch.core.Releasable> listener) throws ConnectTransportException - Specified by:
connectToNodein interfaceConnectionManager- Throws:
ConnectTransportException
-
disconnectFromNode
- Specified by:
disconnectFromNodein interfaceConnectionManager
-
size
public int size()- Specified by:
sizein interfaceConnectionManager
-
getAllConnectedNodes
- Specified by:
getAllConnectedNodesin interfaceConnectionManager
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceConnectionManager
-
closeNoBlock
public void closeNoBlock()- Specified by:
closeNoBlockin interfaceConnectionManager
-
getConnectionProfile
- Specified by:
getConnectionProfilein interfaceConnectionManager
-