IOService (Hazelcast Root 3.12-BETA-2 API)

All Known Implementing Classes:

NodeIOService
```
@PrivateApi
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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`InboundHandler[]`	`createInboundHandlers(EndpointQualifier qualifier, TcpIpConnection connection)`
`OutboundHandler[]`	`createOutboundHandlers(EndpointQualifier qualifier, TcpIpConnection connection)`
`void`	`executeAsync(Runnable runnable)`
`ClientEngine`	`getClientEngine()`
`long`	`getConnectionMonitorInterval()`
`int`	`getConnectionMonitorMaxFaults()`
`EventService`	`getEventService()`
`String`	`getHazelcastName()`
`LoggingService`	`getLoggingService()`
`MemcacheProtocolConfig`	`getMemcacheProtocolConfig()` Returns initialized `MemcacheProtocolConfig` for the node.
`Collection<Integer>`	`getOutboundPorts(EndpointQualifier endpointQualifier)`
`RestApiConfig`	`getRestApiConfig()` Returns initialized `RestApiConfig` for the node.
`InternalSerializationService`	`getSerializationService()`
`int`	`getSocketConnectTimeoutSeconds(EndpointQualifier endpointQualifier)`
`MemberSocketInterceptor`	`getSocketInterceptor(EndpointQualifier endpointQualifier)`
`SSLConfig`	`getSSLConfig(EndpointQualifier endpointQualifier)`
`SymmetricEncryptionConfig`	`getSymmetricEncryptionConfig(EndpointQualifier endpointQualifier)`
`TextCommandService`	`getTextCommandService()`
`Address`	`getThisAddress()`
`Map<EndpointQualifier,Address>`	`getThisAddresses()`
`void`	`interceptSocket(EndpointQualifier endpointQualifier, Socket socket, boolean onAccept)`
`boolean`	`isActive()`
`boolean`	`isSocketBind()`
`boolean`	`isSocketBindAny()`
`boolean`	`isSocketInterceptorEnabled(EndpointQualifier endpointQualifier)`
`void`	`onDisconnect(Address endpoint, Throwable cause)`
`void`	`onFailedConnection(Address address)`
`void`	`onFatalError(Exception e)`
`void`	`onSuccessfulConnection(Address address)`
`HazelcastProperties`	`properties()`
`void`	`removeEndpoint(Address endpoint)`
`void`	`shouldConnectTo(Address address)`

Field Detail
- KILO_BYTE
```
static final int KILO_BYTE
```
  See Also:
  
  Constant Field Values

Method Detail

isActive
```
boolean isActive()
```

properties
```
HazelcastProperties properties()
```

getHazelcastName
```
String getHazelcastName()
```

getLoggingService
```
LoggingService getLoggingService()
```

getThisAddress
```
Address getThisAddress()
```

getThisAddresses
```
Map<EndpointQualifier,Address> getThisAddresses()
```
Returns:

all server socket addresses of this Hazelcast member, as picked by the configured AddressPicker

onFatalError
```
void onFatalError(Exception e)
```

getSymmetricEncryptionConfig

SymmetricEncryptionConfig getSymmetricEncryptionConfig(EndpointQualifier endpointQualifier)

getRestApiConfig
```
RestApiConfig getRestApiConfig()
```
Returns initialized RestApiConfig for the node.

getMemcacheProtocolConfig
```
MemcacheProtocolConfig getMemcacheProtocolConfig()
```
Returns initialized MemcacheProtocolConfig for the node.

getSSLConfig

SSLConfig getSSLConfig(EndpointQualifier endpointQualifier)

getClientEngine
```
ClientEngine getClientEngine()
```

getTextCommandService

TextCommandService getTextCommandService()

removeEndpoint
```
void removeEndpoint(Address endpoint)
```

onSuccessfulConnection

void onSuccessfulConnection(Address address)

onFailedConnection

void onFailedConnection(Address address)

shouldConnectTo
```
void shouldConnectTo(Address address)
```

isSocketBind
```
boolean isSocketBind()
```

isSocketBindAny
```
boolean isSocketBindAny()
```

interceptSocket

void interceptSocket(EndpointQualifier endpointQualifier,
                     Socket socket,
                     boolean onAccept)
              throws IOException

Throws:: IOException

isSocketInterceptorEnabled

boolean isSocketInterceptorEnabled(EndpointQualifier endpointQualifier)

getSocketConnectTimeoutSeconds

int getSocketConnectTimeoutSeconds(EndpointQualifier endpointQualifier)

getConnectionMonitorInterval
```
long getConnectionMonitorInterval()
```

getConnectionMonitorMaxFaults
```
int getConnectionMonitorMaxFaults()
```

onDisconnect

void onDisconnect(Address endpoint,
                  Throwable cause)

executeAsync
```
void executeAsync(Runnable runnable)
```

getEventService
```
EventService getEventService()
```

getOutboundPorts

Collection<Integer> getOutboundPorts(EndpointQualifier endpointQualifier)

getSerializationService

InternalSerializationService getSerializationService()

getSocketInterceptor

MemberSocketInterceptor getSocketInterceptor(EndpointQualifier endpointQualifier)

createInboundHandlers

InboundHandler[] createInboundHandlers(EndpointQualifier qualifier,
                                       TcpIpConnection connection)

createOutboundHandlers

OutboundHandler[] createOutboundHandlers(EndpointQualifier qualifier,
                                         TcpIpConnection connection)

Interface IOService

Field Summary

Method Summary

Field Detail

KILO_BYTE

Method Detail

isActive

properties

getHazelcastName

getLoggingService

getThisAddress

getThisAddresses

onFatalError

getSymmetricEncryptionConfig

getRestApiConfig

getMemcacheProtocolConfig

getSSLConfig

getClientEngine

getTextCommandService

removeEndpoint

onSuccessfulConnection

onFailedConnection

shouldConnectTo

isSocketBind

isSocketBindAny

interceptSocket

isSocketInterceptorEnabled

getSocketConnectTimeoutSeconds

getConnectionMonitorInterval

getConnectionMonitorMaxFaults

onDisconnect

executeAsync

getEventService

getOutboundPorts

getSerializationService

getSocketInterceptor

createInboundHandlers

createOutboundHandlers