Package org.elasticsearch.transport
Class FakeTcpChannel
java.lang.Object
org.elasticsearch.transport.FakeTcpChannel
- All Implemented Interfaces:
Closeable,AutoCloseable,CloseableChannel,TcpChannel
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.transport.TcpChannel
TcpChannel.ChannelStats -
Constructor Summary
ConstructorsConstructorDescriptionFakeTcpChannel(boolean isServer) FakeTcpChannel(boolean isServer, String profile, AtomicReference<BytesReference> messageCaptor) FakeTcpChannel(boolean isServer, InetSocketAddress localAddress, InetSocketAddress remoteAddress) FakeTcpChannel(boolean isServer, InetSocketAddress localAddress, InetSocketAddress remoteAddress, String profile, AtomicReference<BytesReference> messageCaptor) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddCloseListener(ActionListener<Void> listener) voidaddConnectListener(ActionListener<Void> listener) voidclose()booleanisOpen()booleanvoidsendMessage(BytesReference reference, ActionListener<Void> listener) void
-
Constructor Details
-
FakeTcpChannel
public FakeTcpChannel() -
FakeTcpChannel
public FakeTcpChannel(boolean isServer) -
FakeTcpChannel
public FakeTcpChannel(boolean isServer, InetSocketAddress localAddress, InetSocketAddress remoteAddress) -
FakeTcpChannel
public FakeTcpChannel(boolean isServer, String profile, AtomicReference<BytesReference> messageCaptor) -
FakeTcpChannel
public FakeTcpChannel(boolean isServer, InetSocketAddress localAddress, InetSocketAddress remoteAddress, String profile, AtomicReference<BytesReference> messageCaptor)
-
-
Method Details
-
isServerChannel
public boolean isServerChannel()- Specified by:
isServerChannelin interfaceTcpChannel
-
getProfile
- Specified by:
getProfilein interfaceTcpChannel
-
getLocalAddress
- Specified by:
getLocalAddressin interfaceTcpChannel
-
getRemoteAddress
- Specified by:
getRemoteAddressin interfaceTcpChannel
-
sendMessage
- Specified by:
sendMessagein interfaceTcpChannel
-
addConnectListener
- Specified by:
addConnectListenerin interfaceTcpChannel
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceCloseableChannel
-
setCloseException
- Specified by:
setCloseExceptionin interfaceTcpChannel
-
addCloseListener
- Specified by:
addCloseListenerin interfaceCloseableChannel
-
isOpen
public boolean isOpen()- Specified by:
isOpenin interfaceCloseableChannel
-
getChannelStats
- Specified by:
getChannelStatsin interfaceTcpChannel
-
getMessageCaptor
-
getListenerCaptor
-