Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface PublishStore

Hierarchy

  • PublishStore

Implemented by

Index

Methods

Methods

discardUpTo

  • discardUpTo(sequenceId: BigInteger): void

  • Parameters

    • sequenceId: BigInteger

    Returns void

lastPersisted

  • lastPersisted(): BigInteger

  • Returns BigInteger

    The sequence number of the last discarded message.

lowestUnpersisted

  • lowestUnpersisted(): BigInteger

  • 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

  • Parameters

    Returns void

unpersistedCount

  • unpersistedCount(): number

  • Returns number

    The number of messages in the store.