Class MemoryPublishStore

Hierarchy

MemoryPublishStore

Implements

PublishStore

Index

Methods

Methods

discardUpTo

discardUpTo(sequenceId: BigInteger): void

Implementation of PublishStore.discardUpTo

Parameters
- sequenceId: BigInteger
Returns void

lastPersisted

lastPersisted(): BigInteger

Implementation of PublishStore.lastPersisted

Returns BigInteger

The sequence number of the last discarded message.

lowestUnpersisted

lowestUnpersisted(): BigInteger

Implementation of PublishStore.lowestUnpersisted

Returns BigInteger

The oldest sequence number in the store.

replay

replay(messageSender: function): void

Parameters
- messageSender: function
  - - (header: Header, data?: any, timeout?: number): void
    - Parameters
      - header: Header
      - Optional data: any
      - Optional timeout: number
      Returns void
Returns void

replaySingle

replaySingle(messageSender: function, sequenceId: BigInteger): void

Parameters
- messageSender: function
  - - (header: Header, data?: any, timeout?: number): void
    - Parameters
      - header: Header
      - Optional data: any
      - Optional timeout: number
      Returns void
- sequenceId: BigInteger
Returns void

store

store(message: Message): void

Implementation of PublishStore.store

Parameters
- message: Message
Returns void

unpersistedCount

unpersistedCount(): number

Implementation of PublishStore.unpersistedCount

Returns number

The number of messages in the store.