Constructor Detail

• MapDbStatusStorage

  public MapDbStatusStorage(long heartBeatEjectionMilliSeconds,
                            long checkInterval)

  Parameters:

  heartBeatEjectionMilliSeconds - the amount of time before ejecting a given subscriber as failed

  checkInterval - the interval to check for

• MapDbStatusStorage

  public MapDbStatusStorage()

Method Detail

• createUpdatedMap

  public java.util.Map<java.lang.Integer,java.lang.Long> createUpdatedMap()

  Create the storage map

  Specified by:

  createUpdatedMap in class BaseStatusStorage

  Returns:

• createMap

  public java.util.Map<java.lang.Integer,SubscriberState> createMap()

  Description copied from class: BaseStatusStorage
  Create the storage map

  Specified by:

  createMap in class BaseStatusStorage

  Returns:

• getState

  public SubscriberState getState(int id)

  Get the state given an id. The integer represents a stream id for a given ParameterServerSubscriber.

  A SubscriberState is supposed to be 1 to 1 mapping for a stream and a MediaDriver.

  Specified by:

  getState in interface StatusStorage

  Overrides:

  getState in class BaseStatusStorage

  Parameters:

  id - the id of the state to get

  Returns:

  the subscriber state for the given id or none if it doesn't exist