public class MapDbStatusStorage extends BaseStatusStorage
statusStorageMap, updated
Constructor and Description |
---|
MapDbStatusStorage() |
MapDbStatusStorage(long heartBeatEjectionMilliSeconds,
long checkInterval) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.Integer,SubscriberState> |
createMap()
Create the storage map
|
java.util.Map<java.lang.Integer,java.lang.Long> |
createUpdatedMap()
Create the storage map
|
SubscriberState |
getState(int id)
Get the state given an id.
|
ids, numStates, updateState
public MapDbStatusStorage(long heartBeatEjectionMilliSeconds, long checkInterval)
heartBeatEjectionMilliSeconds
- the amount of time before
ejecting a given subscriber as failedcheckInterval
- the interval to check forpublic MapDbStatusStorage()
public java.util.Map<java.lang.Integer,java.lang.Long> createUpdatedMap()
createUpdatedMap
in class BaseStatusStorage
public java.util.Map<java.lang.Integer,SubscriberState> createMap()
BaseStatusStorage
createMap
in class BaseStatusStorage
public SubscriberState getState(int id)
ParameterServerSubscriber
.
A SubscriberState
is supposed to be 1 to 1 mapping
for a stream and a MediaDriver
.
getState
in interface StatusStorage
getState
in class BaseStatusStorage
id
- the id of the state to get