IOService (hazelcast-client-protocol 1.0.0 API)

All Known Implementing Classes:

NodeIOService
```
public interface IOService
```

Field Summary

Fields
Modifier and Type Field and Description

static int KILO_BYTE

Fields
Modifier and Type	Field and Description
`static int`	`KILO_BYTE`

Method Summary

Methods
Modifier and Type	Method and Description
`ReadHandler`	`createReadHandler(TcpIpConnection connection)`
`WriteHandler`	`createWriteHandler(TcpIpConnection connection)`
`void`	`executeAsync(Runnable runnable)`
`int`	`getBalancerIntervalSeconds()`
`long`	`getConnectionMonitorInterval()`
`int`	`getConnectionMonitorMaxFaults()`
`EventService`	`getEventService()`
`int`	`getInputSelectorThreadCount()`
`ILogger`	`getLogger(String name)`
`MemberSocketInterceptor`	`getMemberSocketInterceptor()`
`Collection<Integer>`	`getOutboundPorts()`
`int`	`getOutputSelectorThreadCount()`
`SerializationService`	`getSerializationService()`
`SocketChannelWrapperFactory`	`getSocketChannelWrapperFactory()`
`int`	`getSocketClientReceiveBufferSize()` Size of receive buffers for connections opened by clients
`int`	`getSocketClientSendBufferSize()` Size of send buffers for connections opened by clients
`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`	`handleClientMessage(ClientMessage cm, Connection connection)`
`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()
```

handleClientMessage

void handleClientMessage(ClientMessage cm,
                       Connection connection)

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()
```

getSocketClientReceiveBufferSize
```
int getSocketClientReceiveBufferSize()
```
Size of receive buffers for connections opened by clients

Returns:
size in bytes

getSocketClientSendBufferSize
```
int getSocketClientSendBufferSize()
```
Size of send buffers for connections opened by clients

Returns:
size in bytes

getSocketLingerSeconds
```
int getSocketLingerSeconds()
```

getSocketConnectTimeoutSeconds
```
int getSocketConnectTimeoutSeconds()
```

getSocketKeepAlive
```
boolean getSocketKeepAlive()
```

getSocketNoDelay
```
boolean getSocketNoDelay()
```

getInputSelectorThreadCount
```
int getInputSelectorThreadCount()
```

getOutputSelectorThreadCount
```
int getOutputSelectorThreadCount()
```

getConnectionMonitorInterval
```
long getConnectionMonitorInterval()
```

getConnectionMonitorMaxFaults
```
int getConnectionMonitorMaxFaults()
```

getBalancerIntervalSeconds
```
int getBalancerIntervalSeconds()
```
Returns:
Time interval between two I/O imbalance checks.

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()

getSocketChannelWrapperFactory

SocketChannelWrapperFactory getSocketChannelWrapperFactory()

getMemberSocketInterceptor

MemberSocketInterceptor getMemberSocketInterceptor()

createReadHandler

ReadHandler createReadHandler(TcpIpConnection connection)

createWriteHandler

WriteHandler createWriteHandler(TcpIpConnection connection)

Interface IOService

Field Summary

Method Summary

Field Detail

KILO_BYTE

Method Detail

isActive

getLogger

onOutOfMemory

getThisAddress

onFatalError

getSocketInterceptorConfig

getSymmetricEncryptionConfig

getSSLConfig

handleClientMessage

getTextCommandService

isMemcacheEnabled

isRestEnabled

removeEndpoint

getThreadPrefix

getThreadGroup

onSuccessfulConnection

onFailedConnection

shouldConnectTo

isSocketBind

isSocketBindAny

getSocketReceiveBufferSize

getSocketSendBufferSize

getSocketClientReceiveBufferSize

getSocketClientSendBufferSize

getSocketLingerSeconds

getSocketConnectTimeoutSeconds

getSocketKeepAlive

getSocketNoDelay

getInputSelectorThreadCount

getOutputSelectorThreadCount

getConnectionMonitorInterval

getConnectionMonitorMaxFaults

getBalancerIntervalSeconds

onDisconnect

isClient

executeAsync

getEventService

getOutboundPorts

toData

toObject

getSerializationService

getSocketChannelWrapperFactory

getMemberSocketInterceptor

createReadHandler

createWriteHandler