@PrivateApi public interface NetworkingService<T extends Connection>
EndpointQualifier
an EndpointManager
can be retrieved
by getEndpointManager(EndpointQualifier)
to create or get connections on that end.Modifier and Type | Method and Description |
---|---|
AggregateEndpointManager |
getAggregateEndpointManager()
Return an aggregate endpoint which acts as a view of all endpoints merged together for reporting purposes
eg.
|
EndpointManager<T> |
getEndpointManager(EndpointQualifier qualifier)
Returns the relevant
EndpointManager given an EndpointQualifier
On single-endpoint setups (legacy mode), then a View relevant to the requested Endpoint is returned which purely acts
as a facade to hide the API differences and maintain common signatures. |
IOService |
getIoService()
Returns the I/O Service
|
Networking |
getNetworking()
Returns the Networking engine
Shared across the multiple (or not) endpoints
|
boolean |
isLive()
Flag indicating the liveness status of the Network
|
void |
scheduleDeferred(Runnable task,
long delay,
TimeUnit unit)
Global scheduler for all Endpoints responsible of message retransmission
|
void |
shutdown()
Shutdowns the service completely.
|
void |
start()
Starts the service, initializes its endpoints, starts threads, etc.
|
void |
stop()
Stops the service, releases its resources, stops threads, etc.
|
IOService getIoService()
Networking getNetworking()
AggregateEndpointManager getAggregateEndpointManager()
EndpointManager<T> getEndpointManager(EndpointQualifier qualifier)
EndpointManager
given an EndpointQualifier
On single-endpoint setups (legacy mode), then a View relevant to the requested Endpoint is returned which purely acts
as a facade to hide the API differences and maintain common signatures.
eg.
ProtocolType.MEMBER
-> MemberViewUnifiedEndpointManager
ProtocolType.CLIENT
-> ClientViewUnifiedEndpointManager
com.hazelcast.instance.ProtocolType#TEXT
-> TextViewUnifiedEndpointManager
void scheduleDeferred(Runnable task, long delay, TimeUnit unit)
boolean isLive()
void start()
If it is already started, then this method has no effect.
IllegalStateException
- if NetworkingService is shutdownvoid stop()
start()
.
This method has no effect if it is already stopped or shutdown.
Currently stop
is called during the merge process to detach node from the current cluster. After
node becomes ready to join to the new cluster, start
is called to re-initialize the Endpoints.
void shutdown()
This method has no effect if it is already shutdown.
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.