Class FakeTcpChannel

java.lang.Object

org.opensearch.transport.FakeTcpChannel

All Implemented Interfaces:

Closeable, AutoCloseable, org.opensearch.common.network.CloseableChannel, org.opensearch.transport.TcpChannel

public class FakeTcpChannel
extends Object
implements org.opensearch.transport.TcpChannel

Nested Class Summary

Nested classes/interfaces inherited from interface org.opensearch.transport.TcpChannel

org.opensearch.transport.TcpChannel.ChannelStats

Constructor Summary

Constructors

Constructor	Description
FakeTcpChannel()
FakeTcpChannel(boolean isServer)
FakeTcpChannel(boolean isServer, String profile, AtomicReference<org.opensearch.core.common.bytes.BytesReference> messageCaptor)
FakeTcpChannel(boolean isServer, InetSocketAddress localAddress, InetSocketAddress remoteAddress)
FakeTcpChannel(boolean isServer, InetSocketAddress localAddress, InetSocketAddress remoteAddress, String profile, AtomicReference<org.opensearch.core.common.bytes.BytesReference> messageCaptor)
FakeTcpChannel(boolean isServer, AtomicReference<org.opensearch.core.common.bytes.BytesReference> messageCaptor)

Method Summary

Modifier and Type	Method	Description
void	addCloseListener(org.opensearch.core.action.ActionListener<Void> listener)
void	addConnectListener(org.opensearch.core.action.ActionListener<Void> listener)
void	close()
org.opensearch.transport.TcpChannel.ChannelStats	getChannelStats()
AtomicReference<org.opensearch.core.action.ActionListener<Void>>	getListenerCaptor()
InetSocketAddress	getLocalAddress()
AtomicReference<org.opensearch.core.common.bytes.BytesReference>	getMessageCaptor()
String	getProfile()
InetSocketAddress	getRemoteAddress()
boolean	isOpen()
boolean	isServerChannel()
void	sendMessage(org.opensearch.core.common.bytes.BytesReference reference, org.opensearch.core.action.ActionListener<Void> listener)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opensearch.transport.TcpChannel

get, sendMessage

Constructor Details

FakeTcpChannel

public FakeTcpChannel()

FakeTcpChannel

public FakeTcpChannel(boolean isServer)

FakeTcpChannel

public FakeTcpChannel(boolean isServer,
 InetSocketAddress localAddress,
 InetSocketAddress remoteAddress)

FakeTcpChannel

public FakeTcpChannel(boolean isServer,
 AtomicReference<org.opensearch.core.common.bytes.BytesReference> messageCaptor)

FakeTcpChannel

public FakeTcpChannel(boolean isServer,
 String profile,
 AtomicReference<org.opensearch.core.common.bytes.BytesReference> messageCaptor)

FakeTcpChannel

public FakeTcpChannel(boolean isServer,
 InetSocketAddress localAddress,
 InetSocketAddress remoteAddress,
 String profile,
 AtomicReference<org.opensearch.core.common.bytes.BytesReference> messageCaptor)

Method Details

isServerChannel

public boolean isServerChannel()

Specified by:

isServerChannel in interface org.opensearch.transport.TcpChannel

getProfile

public String getProfile()

Specified by:

getProfile in interface org.opensearch.transport.TcpChannel

getLocalAddress

public InetSocketAddress getLocalAddress()

Specified by:

getLocalAddress in interface org.opensearch.transport.TcpChannel

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Specified by:

getRemoteAddress in interface org.opensearch.transport.TcpChannel

sendMessage

public void sendMessage(org.opensearch.core.common.bytes.BytesReference reference,
 org.opensearch.core.action.ActionListener<Void> listener)

Specified by:

sendMessage in interface org.opensearch.transport.TcpChannel

addConnectListener

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

Specified by:

addConnectListener in interface org.opensearch.transport.TcpChannel

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.opensearch.common.network.CloseableChannel

addCloseListener

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

Specified by:

addCloseListener in interface org.opensearch.common.network.CloseableChannel

isOpen

public boolean isOpen()

Specified by:

isOpen in interface org.opensearch.common.network.CloseableChannel

getChannelStats

public org.opensearch.transport.TcpChannel.ChannelStats getChannelStats()

Specified by:

getChannelStats in interface org.opensearch.transport.TcpChannel

getMessageCaptor

public AtomicReference<org.opensearch.core.common.bytes.BytesReference> getMessageCaptor()

getListenerCaptor

public AtomicReference<org.opensearch.core.action.ActionListener<Void>> getListenerCaptor()