Package one.microstream.communication.types

Class ComConnectionHandler.Default

java.lang.Object

one.microstream.communication.types.ComConnectionHandler.Default

All Implemented Interfaces:

ComConnectionHandler<ComConnection>

Direct Known Subclasses:

ComTLSConnectionHandler

Enclosing interface:

ComConnectionHandler<C>

public static class ComConnectionHandler.Default
extends Object
implements ComConnectionHandler<ComConnection>

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.communication.types.ComConnectionHandler

ComConnectionHandler.Default

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Default()

Method Summary

Modifier and Type	Method	Description
void	close(ComConnection connection)
void	closeReading(ComConnection connection)
void	closeWriting(ComConnection connection)
ComConnectionListener<ComConnection>	createConnectionListener(InetSocketAddress address)
void	enableSecurity(ComConnection connection)
ComConnection	openConnection(InetSocketAddress address)
ComConnection	openConnection(InetSocketAddress address, int retries, Duration retryDelay)
void	prepareReading(ComConnection connection)
void	prepareWriting(ComConnection connection)
void	read(ComConnection connection, ByteBuffer buffer)
void	receiveClientIdentifer(ComConnection connection, ByteBuffer buffer)
ComProtocol	receiveProtocol(ComConnection connection, ComProtocolStringConverter stringConverter)
void	sendClientIdentifer(ComConnection connection, ComPeerIdentifier peerIdentifier)
void	sendProtocol(ComConnection connection, ComProtocol protocol, ComProtocolStringConverter stringConverter)
void	setClientConnectTimeout(int clientConnectTimeout)
void	setInactivityTimeout(ComConnection connection, int inactivityTimeout)
void	write(ComConnection connection, ByteBuffer buffer)

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.microstream.communication.types.ComConnectionHandler

writeChunk

Constructor Details

Default

protected Default()

Method Details

createConnectionListener

public ComConnectionListener<ComConnection> createConnectionListener(InetSocketAddress address)

Specified by:

createConnectionListener in interface ComConnectionHandler<ComConnection>

openConnection

public ComConnection openConnection(InetSocketAddress address)

Specified by:

openConnection in interface ComConnectionHandler<ComConnection>

openConnection

public ComConnection openConnection(InetSocketAddress address, int retries, Duration retryDelay)

Specified by:

openConnection in interface ComConnectionHandler<ComConnection>

prepareReading

public void prepareReading(ComConnection connection)

Specified by:

prepareReading in interface ComConnectionHandler<ComConnection>

prepareWriting

public void prepareWriting(ComConnection connection)

Specified by:

prepareWriting in interface ComConnectionHandler<ComConnection>

close

public void close(ComConnection connection)

Specified by:

close in interface ComConnectionHandler<ComConnection>

closeReading

public void closeReading(ComConnection connection)

Specified by:

closeReading in interface ComConnectionHandler<ComConnection>

closeWriting

public void closeWriting(ComConnection connection)

Specified by:

closeWriting in interface ComConnectionHandler<ComConnection>

read

public void read(ComConnection connection, ByteBuffer buffer)

Specified by:

read in interface ComConnectionHandler<ComConnection>

write

public void write(ComConnection connection, ByteBuffer buffer)

Specified by:

write in interface ComConnectionHandler<ComConnection>

sendClientIdentifer

public void sendClientIdentifer(ComConnection connection, ComPeerIdentifier peerIdentifier)

Specified by:

sendClientIdentifer in interface ComConnectionHandler<ComConnection>

receiveClientIdentifer

public void receiveClientIdentifer(ComConnection connection, ByteBuffer buffer)

Specified by:

receiveClientIdentifer in interface ComConnectionHandler<ComConnection>

sendProtocol

public void sendProtocol(ComConnection connection, ComProtocol protocol, ComProtocolStringConverter stringConverter)

Specified by:

sendProtocol in interface ComConnectionHandler<ComConnection>

receiveProtocol

public ComProtocol receiveProtocol(ComConnection connection, ComProtocolStringConverter stringConverter)

Specified by:

receiveProtocol in interface ComConnectionHandler<ComConnection>

enableSecurity

public void enableSecurity(ComConnection connection)

Specified by:

enableSecurity in interface ComConnectionHandler<ComConnection>

setInactivityTimeout

public void setInactivityTimeout(ComConnection connection, int inactivityTimeout)

Specified by:

setInactivityTimeout in interface ComConnectionHandler<ComConnection>

setClientConnectTimeout

public void setClientConnectTimeout(int clientConnectTimeout)

Specified by:

setClientConnectTimeout in interface ComConnectionHandler<ComConnection>