Class StubbableTransport.WrappedConnection

java.lang.Object

org.opensearch.test.transport.StubbableTransport.WrappedConnection

All Implemented Interfaces:

Closeable, AutoCloseable, org.opensearch.transport.Transport.Connection

Enclosing class:

StubbableTransport

public class StubbableTransport.WrappedConnection
extends Object
implements org.opensearch.transport.Transport.Connection

Method Summary

Modifier and Type	Method	Description
void	addCloseListener(org.opensearch.core.action.ActionListener<Void> listener)
void	close()
Object	getCacheKey()
org.opensearch.transport.Transport.Connection	getConnection()
org.opensearch.cluster.node.DiscoveryNode	getNode()
org.opensearch.Version	getVersion()
boolean	isClosed()
void	sendRequest(long requestId, String action, org.opensearch.transport.TransportRequest request, org.opensearch.transport.TransportRequestOptions options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getNode

public org.opensearch.cluster.node.DiscoveryNode getNode()

Specified by:

getNode in interface org.opensearch.transport.Transport.Connection

sendRequest

public void sendRequest(long requestId,
 String action,
 org.opensearch.transport.TransportRequest request,
 org.opensearch.transport.TransportRequestOptions options)
                 throws IOException,
org.opensearch.transport.TransportException

Specified by:

sendRequest in interface org.opensearch.transport.Transport.Connection

Throws:

IOException

org.opensearch.transport.TransportException

addCloseListener

public void addCloseListener(org.opensearch.core.action.ActionListener<Void> listener)

Specified by:

addCloseListener in interface org.opensearch.transport.Transport.Connection

isClosed

public boolean isClosed()

Specified by:

isClosed in interface org.opensearch.transport.Transport.Connection

getVersion

public org.opensearch.Version getVersion()

Specified by:

getVersion in interface org.opensearch.transport.Transport.Connection

getCacheKey

public Object getCacheKey()

Specified by:

getCacheKey in interface org.opensearch.transport.Transport.Connection

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.opensearch.transport.Transport.Connection

getConnection

public org.opensearch.transport.Transport.Connection getConnection()