Constructor and Description |
---|
NodeIOService(Node node,
NodeEngineImpl nodeEngine) |
public NodeIOService(Node node, NodeEngineImpl nodeEngine)
public void onOutOfMemory(OutOfMemoryError oom)
onOutOfMemory
in interface IOService
public Address getThisAddress()
getThisAddress
in interface IOService
public void onFatalError(Exception e)
onFatalError
in interface IOService
public SocketInterceptorConfig getSocketInterceptorConfig()
getSocketInterceptorConfig
in interface IOService
public SymmetricEncryptionConfig getSymmetricEncryptionConfig()
getSymmetricEncryptionConfig
in interface IOService
public SSLConfig getSSLConfig()
getSSLConfig
in interface IOService
public void handleClientPacket(Packet p)
handleClientPacket
in interface IOService
public void handleClientMessage(ClientMessage cm, Connection connection)
handleClientMessage
in interface IOService
public TextCommandService getTextCommandService()
getTextCommandService
in interface IOService
public boolean isMemcacheEnabled()
isMemcacheEnabled
in interface IOService
public boolean isRestEnabled()
isRestEnabled
in interface IOService
public void removeEndpoint(Address endPoint)
removeEndpoint
in interface IOService
public String getThreadPrefix()
getThreadPrefix
in interface IOService
public ThreadGroup getThreadGroup()
getThreadGroup
in interface IOService
public void onSuccessfulConnection(Address address)
onSuccessfulConnection
in interface IOService
public void onFailedConnection(Address address)
onFailedConnection
in interface IOService
public void shouldConnectTo(Address address)
shouldConnectTo
in interface IOService
public boolean isSocketBind()
isSocketBind
in interface IOService
public boolean isSocketBindAny()
isSocketBindAny
in interface IOService
public int getSocketReceiveBufferSize()
getSocketReceiveBufferSize
in interface IOService
public int getSocketSendBufferSize()
getSocketSendBufferSize
in interface IOService
public int getSocketClientReceiveBufferSize()
IOService
getSocketClientReceiveBufferSize
in interface IOService
public int getSocketClientSendBufferSize()
IOService
getSocketClientSendBufferSize
in interface IOService
public int getSocketLingerSeconds()
getSocketLingerSeconds
in interface IOService
public int getSocketConnectTimeoutSeconds()
getSocketConnectTimeoutSeconds
in interface IOService
public boolean getSocketKeepAlive()
getSocketKeepAlive
in interface IOService
public boolean getSocketNoDelay()
getSocketNoDelay
in interface IOService
public int getInputSelectorThreadCount()
getInputSelectorThreadCount
in interface IOService
public int getOutputSelectorThreadCount()
getOutputSelectorThreadCount
in interface IOService
public void onDisconnect(Address endpoint)
onDisconnect
in interface IOService
public long getConnectionMonitorInterval()
getConnectionMonitorInterval
in interface IOService
public int getConnectionMonitorMaxFaults()
getConnectionMonitorMaxFaults
in interface IOService
public int getBalancerIntervalSeconds()
getBalancerIntervalSeconds
in interface IOService
public void executeAsync(Runnable runnable)
executeAsync
in interface IOService
public EventService getEventService()
getEventService
in interface IOService
public SerializationService getSerializationService()
getSerializationService
in interface IOService
public SocketChannelWrapperFactory getSocketChannelWrapperFactory()
getSocketChannelWrapperFactory
in interface IOService
public MemberSocketInterceptor getMemberSocketInterceptor()
getMemberSocketInterceptor
in interface IOService
public ReadHandler createReadHandler(TcpIpConnection connection)
createReadHandler
in interface IOService
public WriteHandler createWriteHandler(TcpIpConnection connection)
createWriteHandler
in interface IOService
public Collection<Integer> getOutboundPorts()
getOutboundPorts
in interface IOService
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.