Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ServerSidePublishEngineForOrphanSubscription

the ServerSidePublishEngineForOrphanSubscription is keeping track of live subscription that have been detached from timed out session. It takes care of providing back those subscription to any session that will claim them again with transferSubscription service It also make sure that subscription are properly disposed when they expire.

Hierarchy

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Properties

isSessionClosed

isSessionClosed: boolean = false

maxPublishRequestInQueue

maxPublishRequestInQueue: number = 0

Static defaultMaxListeners

defaultMaxListeners: number

Static registry

registry: ObjectRegistry = new ObjectRegistry()

Accessors

currentMonitoredItemCount

  • get currentMonitoredItemCount(): number

hasLateSubscriptions

  • get hasLateSubscriptions(): boolean

pendingClosedSubscriptionCount

  • get pendingClosedSubscriptionCount(): number

pendingPublishRequestCount

  • get pendingPublishRequestCount(): number

subscriptionCount

  • get subscriptionCount(): number

subscriptions

Methods

Private _on_PublishRequest

  • _on_PublishRequest(request: PublishRequest, callback: any): void

addListener

  • addListener(event: string | symbol, listener: function): this

  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

add_subscription

Private cancelPendingPublishRequest

  • cancelPendingPublishRequest(): void

cancelPendingPublishRequestBeforeChannelChange

  • cancelPendingPublishRequestBeforeChannelChange(): void

detach_subscription

dispose

  • dispose(): void

emit

  • emit(event: string | symbol, ...args: any[]): boolean

  • Parameters

    • event: string | symbol
    • Rest ...args: any[]

    Returns boolean

eventNames

  • eventNames(): Array<string | symbol>

  • Returns Array<string | symbol>

findLateSubscriptionSortedByPriority

findLateSubscriptions

findLateSubscriptionsSortedByAge

findSubscriptionWaitingForFirstPublish

getMaxListeners

  • getMaxListeners(): number

  • Returns number

getSubscriptionById

  • getSubscriptionById(subscriptionId: number | string): Subscription

listenerCount

  • listenerCount(type: string | symbol): number

  • Parameters

    • type: string | symbol

    Returns number

listeners

  • listeners(event: string | symbol): Function[]

  • Parameters

    • event: string | symbol

    Returns Function[]

off

  • off(event: string | symbol, listener: function): this

  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

on

  • on(event: string | symbol, listener: function): this

  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

onSessionClose

  • onSessionClose(): void

on_close_subscription

once

  • once(event: string | symbol, listener: function): this

  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

prependListener

  • prependListener(event: string | symbol, listener: function): this

  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

prependOnceListener

  • prependOnceListener(event: string | symbol, listener: function): this

  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

process_subscriptionAcknowledgements

  • process_subscriptionAcknowledgements(subscriptionAcknowledgements: SubscriptionAcknowledgement[]): StatusCode[]

rawListeners

  • rawListeners(event: string | symbol): Function[]

  • Parameters

    • event: string | symbol

    Returns Function[]

removeAllListeners

  • removeAllListeners(event?: string | symbol): this

  • Parameters

    • Optional event: string | symbol

    Returns this

removeListener

  • removeListener(event: string | symbol, listener: function): this

  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

setMaxListeners

  • setMaxListeners(n: number): this

  • Parameters

    • n: number

    Returns this

shutdown

  • shutdown(): void

Static listenerCount

  • listenerCount(emitter: EventEmitter, event: string | symbol): number
  • deprecated

    since v4.0.0

    Parameters

    • emitter: EventEmitter
    • event: string | symbol

    Returns number

Static Private transferSubscription

Static Private transferSubscriptionsToOrphan

Generated using TypeDoc