@PrivateApi public class NodeIOService extends Object implements IOService
Constructor and Description |
---|
NodeIOService(Node node,
NodeEngineImpl nodeEngine) |
public NodeIOService(Node node, NodeEngineImpl nodeEngine)
public HazelcastProperties properties()
properties
in interface IOService
public String getHazelcastName()
getHazelcastName
in interface IOService
public LoggingService getLoggingService()
getLoggingService
in interface IOService
public Address getThisAddress()
getThisAddress
in interface IOService
public void onFatalError(Exception e)
onFatalError
in interface IOService
public SocketInterceptorConfig getSocketInterceptorConfig()
public SymmetricEncryptionConfig getSymmetricEncryptionConfig()
getSymmetricEncryptionConfig
in interface IOService
public SSLConfig getSSLConfig()
getSSLConfig
in interface IOService
public ClientEngine getClientEngine()
getClientEngine
in interface IOService
public TextCommandService getTextCommandService()
getTextCommandService
in interface IOService
public void removeEndpoint(Address endPoint)
removeEndpoint
in interface IOService
public void onDisconnect(Address endpoint, Throwable cause)
onDisconnect
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 void interceptSocket(Socket socket, boolean onAccept) throws IOException
interceptSocket
in interface IOService
IOException
public boolean isSocketInterceptorEnabled()
isSocketInterceptorEnabled
in interface IOService
public int getSocketConnectTimeoutSeconds()
getSocketConnectTimeoutSeconds
in interface IOService
public long getConnectionMonitorInterval()
getConnectionMonitorInterval
in interface IOService
public int getConnectionMonitorMaxFaults()
getConnectionMonitorMaxFaults
in interface IOService
public void executeAsync(Runnable runnable)
executeAsync
in interface IOService
public EventService getEventService()
getEventService
in interface IOService
public InternalSerializationService getSerializationService()
getSerializationService
in interface IOService
public MemberSocketInterceptor getMemberSocketInterceptor()
getMemberSocketInterceptor
in interface IOService
public InboundHandler[] createMemberInboundHandlers(TcpIpConnection connection)
createMemberInboundHandlers
in interface IOService
public OutboundHandler[] createMemberOutboundHandlers(TcpIpConnection connection)
createMemberOutboundHandlers
in interface IOService
public Collection<Integer> getOutboundPorts()
getOutboundPorts
in interface IOService
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.