Package org.elasticsearch.test.transport
Class StubbableTransport.WrappedConnection
java.lang.Object
org.elasticsearch.test.transport.StubbableTransport.WrappedConnection
- All Implemented Interfaces:
Closeable,AutoCloseable,org.elasticsearch.core.RefCounted,Transport.Connection
- Enclosing class:
StubbableTransport
-
Field Summary
Fields inherited from interface org.elasticsearch.core.RefCounted
ALWAYS_REFERENCED -
Method Summary
Modifier and TypeMethodDescriptionvoidaddCloseListener(ActionListener<Void> listener) voidaddRemovedListener(ActionListener<Void> listener) voidclose()booleandecRef()getNode()booleanvoidincRef()booleanisClosed()voidvoidsendRequest(long requestId, String action, TransportRequest request, TransportRequestOptions options) toString()booleanMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.core.RefCounted
mustIncRef
-
Method Details
-
getNode
- Specified by:
getNodein interfaceTransport.Connection
-
sendRequest
public void sendRequest(long requestId, String action, TransportRequest request, TransportRequestOptions options) throws IOException, TransportException - Specified by:
sendRequestin interfaceTransport.Connection- Throws:
IOExceptionTransportException
-
addCloseListener
- Specified by:
addCloseListenerin interfaceTransport.Connection
-
addRemovedListener
- Specified by:
addRemovedListenerin interfaceTransport.Connection
-
isClosed
public boolean isClosed()- Specified by:
isClosedin interfaceTransport.Connection
-
getTransportVersion
- Specified by:
getTransportVersionin interfaceTransport.Connection
-
getCacheKey
- Specified by:
getCacheKeyin interfaceTransport.Connection
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceTransport.Connection
-
onRemoved
public void onRemoved()- Specified by:
onRemovedin interfaceTransport.Connection
-
getConnection
-
toString
-
incRef
public void incRef()- Specified by:
incRefin interfaceorg.elasticsearch.core.RefCounted
-
tryIncRef
public boolean tryIncRef()- Specified by:
tryIncRefin interfaceorg.elasticsearch.core.RefCounted
-
decRef
public boolean decRef()- Specified by:
decRefin interfaceorg.elasticsearch.core.RefCounted
-
hasReferences
public boolean hasReferences()- Specified by:
hasReferencesin interfaceorg.elasticsearch.core.RefCounted
-