org.shared.test.net

Class ClientServerTest.Utf8Handler

java.lang.Object

org.shared.net.handler.AbstractFilteredHandler<ClientServerTest.Utf8Handler,Connection,String>

org.shared.test.net.ClientServerTest.Utf8Handler

All Implemented Interfaces:

Closeable, AutoCloseable, ConnectionHandler<Connection>, Filter<String,ByteBuffer>, FilterFactory<Filter<String,ByteBuffer>,String,ByteBuffer,ClientServerTest.Utf8Handler>, FilteredHandler<ClientServerTest.Utf8Handler,Connection,String>, OobHandler<Connection>

Enclosing class:

ClientServerTest

protected static class ClientServerTest.Utf8Handler
extends AbstractFilteredHandler<ClientServerTest.Utf8Handler,Connection,String>
implements FilterFactory<Filter<String,ByteBuffer>,String,ByteBuffer,ClientServerTest.Utf8Handler>, Filter<String,ByteBuffer>

An internal Connection class for demo purposes.

Nested Class Summary

Nested classes/interfaces inherited from interface org.shared.net.ConnectionHandler

ConnectionHandler.ClosingType

Field Summary

Fields inherited from class org.shared.net.handler.AbstractFilteredHandler

dummyFuture

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClientServerTest.Utf8Handler(String name) Default constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	applyInbound(Queue<ByteBuffer> inputs, Queue<String> outputs) Filters traffic in the inbound direction.
void	applyOutbound(Queue<String> inputs, Queue<ByteBuffer> outputs) Filters traffic in the outbound direction.
Filter<String,ByteBuffer>	newFilter(ClientServerTest.Utf8Handler handler) Creates a new Filter.
void	onBind(Queue<String> inputs) On binding.
void	onClose() On completion of closure.
void	onClosing(ConnectionHandler.ClosingType type, Queue<String> inputs) On closure.
void	onReceive(Queue<String> inputs) On receipt of data.

Methods inherited from class org.shared.net.handler.AbstractFilteredHandler

close, getConnection, onBind, onClosing, onOob, onOob, onReceive, send, setConnection, setFilterFactory, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientServerTest.Utf8Handler

protected ClientServerTest.Utf8Handler(String name)

Default constructor.

Method Detail

onBind

public void onBind(Queue<String> inputs)

Description copied from interface: FilteredHandler

On binding.

Specified by:

onBind in interface FilteredHandler<ClientServerTest.Utf8Handler,Connection,String>

Parameters:

inputs - the input Queue.

onReceive

public void onReceive(Queue<String> inputs)

Description copied from interface: FilteredHandler

On receipt of data.

Specified by:

onReceive in interface FilteredHandler<ClientServerTest.Utf8Handler,Connection,String>

Parameters:

inputs - the input Queue.

onClosing

public void onClosing(ConnectionHandler.ClosingType type,
             Queue<String> inputs)

Description copied from interface: FilteredHandler

On closure.

Specified by:

onClosing in interface FilteredHandler<ClientServerTest.Utf8Handler,Connection,String>

Parameters:

type - the ConnectionHandler.ClosingType.

inputs - the input Queue.

See Also:

ConnectionHandler.ClosingType

onClose

public void onClose()

Description copied from interface: ConnectionHandler

On completion of closure.

Specified by:

onClose in interface ConnectionHandler<Connection>

newFilter

public Filter<String,ByteBuffer> newFilter(ClientServerTest.Utf8Handler handler)

Description copied from interface: FilterFactory

Creates a new Filter.

Specified by:

newFilter in interface FilterFactory<Filter<String,ByteBuffer>,String,ByteBuffer,ClientServerTest.Utf8Handler>

applyInbound

public void applyInbound(Queue<ByteBuffer> inputs,
                Queue<String> outputs)

Description copied from interface: Filter

Filters traffic in the inbound direction.

Specified by:

applyInbound in interface Filter<String,ByteBuffer>

Parameters:

inputs - the input Queue.

outputs - the output Queue.

applyOutbound

public void applyOutbound(Queue<String> inputs,
                 Queue<ByteBuffer> outputs)

Description copied from interface: Filter

Filters traffic in the outbound direction.

Specified by:

applyOutbound in interface Filter<String,ByteBuffer>

Parameters:

inputs - the input Queue.

outputs - the output Queue.