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)


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.