Package org.elasticsearch.transport

Class MockTcpTransport.MockChannel

java.lang.Object

org.elasticsearch.transport.MockTcpTransport.MockChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Releasable, TcpChannel

Enclosing class:

MockTcpTransport

public final class MockTcpTransport.MockChannel
extends java.lang.Object
implements java.io.Closeable, TcpChannel

Constructor Summary

Constructors

Constructor	Description
MockChannel(java.net.ServerSocket serverSocket, java.lang.String profile)	Constructs a new MockChannel instance intended for accepting requests.
MockChannel(java.net.Socket socket, java.net.InetSocketAddress localAddress, java.lang.String profile, java.util.function.Consumer<MockTcpTransport.MockChannel> onClose)	Constructs a new MockChannel instance intended for handling the actual incoming / outgoing traffic.

Method Summary

Modifier and Type	Method	Description
void	accept(java.util.concurrent.Executor executor)
void	addCloseListener(ActionListener<java.lang.Void> listener)
void	close()
void	close0()
java.net.InetSocketAddress	getLocalAddress()
boolean	isOpen()
void	loopRead(java.util.concurrent.Executor executor)
void	sendMessage(BytesReference reference, ActionListener<java.lang.Void> listener)
void	setSoLinger(int value)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.TcpChannel

Constructor Detail

MockChannel

public MockChannel(java.net.Socket socket,
                   java.net.InetSocketAddress localAddress,
                   java.lang.String profile,
                   java.util.function.Consumer<MockTcpTransport.MockChannel> onClose)

Constructs a new MockChannel instance intended for handling the actual incoming / outgoing traffic.

Parameters:

socket - The client socket. Mut not be null.

localAddress - Address associated with the corresponding local server socket. Must not be null.

profile - The associated profile name.

onClose - Callback to execute when this channel is closed.

MockChannel

public MockChannel(java.net.ServerSocket serverSocket,
                   java.lang.String profile)

Constructs a new MockChannel instance intended for accepting requests.

Parameters:

serverSocket - The associated server socket. Must not be null.

profile - The associated profile name.

Method Detail

accept

public void accept(java.util.concurrent.Executor executor)
            throws java.io.IOException

Throws:

java.io.IOException

loopRead

public void loopRead(java.util.concurrent.Executor executor)

close0

public void close0()
            throws java.io.IOException

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface Releasable

Specified by:

close in interface TcpChannel

addCloseListener

public void addCloseListener(ActionListener<java.lang.Void> listener)

Specified by:

addCloseListener in interface TcpChannel

setSoLinger

public void setSoLinger(int value)
                 throws java.io.IOException

Specified by:

setSoLinger in interface TcpChannel

Throws:

java.io.IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface TcpChannel

getLocalAddress

public java.net.InetSocketAddress getLocalAddress()

Specified by:

getLocalAddress in interface TcpChannel

sendMessage

public void sendMessage(BytesReference reference,
                        ActionListener<java.lang.Void> listener)

Specified by:

sendMessage in interface TcpChannel