com.hazelcast.nio
Interface IOService

All Known Implementing Classes:

NodeIOService

public interface IOService

Field Summary

static int

KILO_BYTE

Method Summary

PacketReader	createPacketReader(TcpIpConnection connection)
PacketWriter	createPacketWriter(TcpIpConnection connection)
void	executeAsync(Runnable runnable)
long	getConnectionMonitorInterval()
int	getConnectionMonitorMaxFaults()
EventService	getEventService()
ILogger	getLogger(String name)
MemberSocketInterceptor	getMemberSocketInterceptor()
Collection<Integer>	getOutboundPorts()
PortableContext	getPortableContext()
int	getSelectorThreadCount()
SerializationService	getSerializationService()
SocketChannelWrapperFactory	getSocketChannelWrapperFactory()
int	getSocketConnectTimeoutSeconds()
SocketInterceptorConfig	getSocketInterceptorConfig()
boolean	getSocketKeepAlive()
int	getSocketLingerSeconds()
boolean	getSocketNoDelay()
int	getSocketReceiveBufferSize()
int	getSocketSendBufferSize()
SSLConfig	getSSLConfig()
SymmetricEncryptionConfig	getSymmetricEncryptionConfig()
TextCommandService	getTextCommandService()
Address	getThisAddress()
ThreadGroup	getThreadGroup()
String	getThreadPrefix()
void	handleClientPacket(Packet p)
void	handleMemberPacket(Packet p)
boolean	isActive()
boolean	isClient()
boolean	isMemcacheEnabled()
boolean	isRestEnabled()
boolean	isSocketBind()
boolean	isSocketBindAny()
void	onDisconnect(Address endpoint)
void	onFailedConnection(Address address)
void	onFatalError(Exception e)
void	onOutOfMemory(OutOfMemoryError oom)
void	onSuccessfulConnection(Address address)
void	removeEndpoint(Address endpoint)
void	shouldConnectTo(Address address)
Data	toData(Object obj)
Object	toObject(Data data)

Field Detail

KILO_BYTE

static final int KILO_BYTE

See Also:

Constant Field Values

Method Detail

isActive

boolean isActive()

getLogger

ILogger getLogger(String name)

onOutOfMemory

void onOutOfMemory(OutOfMemoryError oom)

getThisAddress

Address getThisAddress()

onFatalError

void onFatalError(Exception e)

getSocketInterceptorConfig

SocketInterceptorConfig getSocketInterceptorConfig()

getSymmetricEncryptionConfig

SymmetricEncryptionConfig getSymmetricEncryptionConfig()

getSSLConfig

SSLConfig getSSLConfig()

handleMemberPacket

void handleMemberPacket(Packet p)

handleClientPacket

void handleClientPacket(Packet p)

getTextCommandService

TextCommandService getTextCommandService()

isMemcacheEnabled

boolean isMemcacheEnabled()

isRestEnabled

boolean isRestEnabled()

removeEndpoint

void removeEndpoint(Address endpoint)

getThreadPrefix

String getThreadPrefix()

getThreadGroup

ThreadGroup getThreadGroup()

onSuccessfulConnection

void onSuccessfulConnection(Address address)

onFailedConnection

void onFailedConnection(Address address)

shouldConnectTo

void shouldConnectTo(Address address)

isSocketBind

boolean isSocketBind()

isSocketBindAny

boolean isSocketBindAny()

getSocketReceiveBufferSize

int getSocketReceiveBufferSize()

getSocketSendBufferSize

int getSocketSendBufferSize()

getSocketLingerSeconds

int getSocketLingerSeconds()

getSocketConnectTimeoutSeconds

int getSocketConnectTimeoutSeconds()

getSocketKeepAlive

boolean getSocketKeepAlive()

getSocketNoDelay

boolean getSocketNoDelay()

getSelectorThreadCount

int getSelectorThreadCount()

getConnectionMonitorInterval

long getConnectionMonitorInterval()

getConnectionMonitorMaxFaults

int getConnectionMonitorMaxFaults()

onDisconnect

void onDisconnect(Address endpoint)

isClient

boolean isClient()

executeAsync

void executeAsync(Runnable runnable)

getEventService

EventService getEventService()

getOutboundPorts

Collection<Integer> getOutboundPorts()

toData

Data toData(Object obj)

toObject

Object toObject(Data data)

getSerializationService

SerializationService getSerializationService()

getPortableContext

PortableContext getPortableContext()

getSocketChannelWrapperFactory

SocketChannelWrapperFactory getSocketChannelWrapperFactory()

getMemberSocketInterceptor

MemberSocketInterceptor getMemberSocketInterceptor()

createPacketReader

PacketReader createPacketReader(TcpIpConnection connection)

createPacketWriter

PacketWriter createPacketWriter(TcpIpConnection connection)