@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 Map<EndpointQualifier,Address> getThisAddresses()
getThisAddresses
in interface IOService
AddressPicker
public void onFatalError(Exception e)
onFatalError
in interface IOService
public SocketInterceptorConfig getSocketInterceptorConfig(EndpointQualifier endpointQualifier)
public SymmetricEncryptionConfig getSymmetricEncryptionConfig(EndpointQualifier endpointQualifier)
getSymmetricEncryptionConfig
in interface IOService
public SSLConfig getSSLConfig(EndpointQualifier endpointQualifier)
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(EndpointQualifier endpointQualifier, Socket socket, boolean onAccept) throws IOException
interceptSocket
in interface IOService
IOException
public boolean isSocketInterceptorEnabled(EndpointQualifier endpointQualifier)
isSocketInterceptorEnabled
in interface IOService
public int getSocketConnectTimeoutSeconds(EndpointQualifier endpointQualifier)
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 getSocketInterceptor(EndpointQualifier endpointQualifier)
getSocketInterceptor
in interface IOService
public InboundHandler[] createInboundHandlers(EndpointQualifier qualifier, TcpIpConnection connection)
createInboundHandlers
in interface IOService
public OutboundHandler[] createOutboundHandlers(EndpointQualifier qualifier, TcpIpConnection connection)
createOutboundHandlers
in interface IOService
public Collection<Integer> getOutboundPorts(EndpointQualifier endpointQualifier)
getOutboundPorts
in interface IOService
public RestApiConfig getRestApiConfig()
IOService
RestApiConfig
for the node.getRestApiConfig
in interface IOService
public MemcacheProtocolConfig getMemcacheProtocolConfig()
IOService
MemcacheProtocolConfig
for the node.getMemcacheProtocolConfig
in interface IOService
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.