HazelcastDiscoveryService

java.lang.Object
- pl.edu.agh.age.services.discovery.internal.HazelcastDiscoveryService

All Implemented Interfaces:

org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, DiscoveryService
```
@Named
public final class HazelcastDiscoveryService
extends java.lang.Object
implements org.springframework.context.SmartLifecycle, DiscoveryService
```

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

private static class HazelcastDiscoveryService.MapUpdateCallback

private class HazelcastDiscoveryService.NeighbourMapListener

Nested Classes
Modifier and Type	Class and Description
`private static class`	`HazelcastDiscoveryService.MapUpdateCallback`
`private class`	`HazelcastDiscoveryService.NeighbourMapListener`

Field Summary

Fields
Modifier and Type	Field and Description
`private java.lang.String`	`entryListenerId`
`private EventBus`	`eventBus`
`private ListeningScheduledExecutorService`	`executorService`
`private HazelcastInstance`	`hazelcastInstance`
`private NodeIdentityService`	`identityService`
`private static org.slf4j.Logger`	`logger`
`private IMap<java.lang.String,NodeDescriptor>`	`members`
`private java.lang.String`	`nodeId`
`private java.util.concurrent.atomic.AtomicBoolean`	`running`
`private static @s long`	`UPDATE_PERIOD_IN_S`

Constructor Summary

Constructors
Constructor and Description
`HazelcastDiscoveryService(HazelcastInstance hazelcastInstance, EventBus eventBus, NodeIdentityService identityService)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`java.util.Set<NodeDescriptor>`	`allMembers()` Returns `NodeDescriptor`s of all cluster members.
`private void`	`cleanUp()`
`int`	`getPhase()`
`boolean`	`isAutoStartup()`
`boolean`	`isRunning()`
`java.util.Set<NodeDescriptor>`	`membersMatching(java.lang.String criteria)` Returns `NodeDescriptor`s of cluster members matching the given criteria.
`java.util.Optional<NodeDescriptor>`	`memberWithId(java.lang.String id)` Returns `NodeDescriptor` for the node with the given ID.
`private void`	`onHazelcastStateChange(LifecycleEvent event)`
`void`	`start()`
`void`	`stop()`
`void`	`stop(java.lang.Runnable callback)`
`private void`	`updateMap()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - UPDATE_PERIOD_IN_S
```
private static final @s long UPDATE_PERIOD_IN_S
```
    See Also:
    
    Constant Field Values
  - logger
```
private static final org.slf4j.Logger logger
```
  - executorService
```
private final ListeningScheduledExecutorService executorService
```
  - running
```
private final java.util.concurrent.atomic.AtomicBoolean running
```
  - hazelcastInstance
```
private final HazelcastInstance hazelcastInstance
```
  - identityService
```
private final NodeIdentityService identityService
```
  - eventBus
```
private final EventBus eventBus
```
  - members
```
private final IMap<java.lang.String,NodeDescriptor> members
```
  - nodeId
```
private final java.lang.String nodeId
```
  - entryListenerId
```
private final java.lang.String entryListenerId
```
- Constructor Detail
  - HazelcastDiscoveryService
```
@Inject
public HazelcastDiscoveryService(HazelcastInstance hazelcastInstance,
                                         EventBus eventBus,
                                         NodeIdentityService identityService)
```
- Method Detail
  - isAutoStartup
```
public boolean isAutoStartup()
```
    Specified by:
    
    isAutoStartup in interface org.springframework.context.SmartLifecycle
  - stop
```
public void stop(java.lang.Runnable callback)
```
    Specified by:
    
    stop in interface org.springframework.context.SmartLifecycle
  - start
```
public void start()
```
    Specified by:
    
    start in interface org.springframework.context.Lifecycle
  - stop
```
public void stop()
```
    Specified by:
    
    stop in interface org.springframework.context.Lifecycle
  - isRunning
```
public boolean isRunning()
```
    Specified by:
    
    isRunning in interface org.springframework.context.Lifecycle
  - getPhase
```
public int getPhase()
```
    Specified by:
    
    getPhase in interface org.springframework.context.Phased
  - membersMatching
```
public java.util.Set<NodeDescriptor> membersMatching(java.lang.String criteria)
```
    Description copied from interface: DiscoveryService
    
    Returns NodeDescriptors of cluster members matching the given criteria.
    
    Specified by:
    
    membersMatching in interface DiscoveryService
    
    Parameters:
    
    criteria - Criteria in the form of SQL query.
    
    Returns:
    
    A set of node descriptors.
    
    See Also:
    
    SqlPredicate
  - allMembers
```
public java.util.Set<NodeDescriptor> allMembers()
```
    Description copied from interface: DiscoveryService
    
    Returns NodeDescriptors of all cluster members.
    
    Specified by:
    
    allMembers in interface DiscoveryService
    
    Returns:
    
    A set of node descriptors.
  - memberWithId
```
public java.util.Optional<NodeDescriptor> memberWithId(java.lang.String id)
```
    Description copied from interface: DiscoveryService
    
    Returns NodeDescriptor for the node with the given ID.
    
    Specified by:
    
    memberWithId in interface DiscoveryService
    
    Parameters:
    
    id - an ID to look up.
    
    Returns:
    
    a matching NodeDescriptor or empty Optional if there is no such member.
  - updateMap
```
private void updateMap()
```
  - cleanUp
```
private void cleanUp()
```
  - onHazelcastStateChange
```
private void onHazelcastStateChange(LifecycleEvent event)
```

Class HazelcastDiscoveryService

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

UPDATE_PERIOD_IN_S

logger

executorService

running

hazelcastInstance

identityService

eventBus

members

nodeId

entryListenerId

Constructor Detail

HazelcastDiscoveryService

Method Detail

isAutoStartup

stop

start

stop

isRunning

getPhase

membersMatching

allMembers

memberWithId

updateMap

cleanUp

onHazelcastStateChange