Options
All
  • Public
  • Public/Protected
  • All
Menu

  subscribe now with sterfive to access the online-user manual

A client side implementation to deal with publish service.

param

the client session

Hierarchy

  • ClientSidePublishEngine

Index

Constructors

constructor

Properties

activeSubscriptionCount

activeSubscriptionCount: number

isSuspended

isSuspended: boolean

nbMaxPublishRequestsAcceptedByServer

nbMaxPublishRequestsAcceptedByServer: number

nbPendingPublishRequests

nbPendingPublishRequests: number

session

session: ClientSession

timeoutHint

timeoutHint: number

Static publishRequestCountInPipeline

publishRequestCountInPipeline: number

Accessors

subscriptionCount

  • get subscriptionCount(): number
  • the number of active subscriptions managed by this publish engine.

    property

    subscriptionCount

    Returns number

Methods

acknowledge_notification

  • acknowledge_notification(subscriptionId: number, sequenceNumber: number): void
  • Parameters

    • subscriptionId: number
    • sequenceNumber: number

    Returns void

cleanup_acknowledgment_for_subscription

  • cleanup_acknowledgment_for_subscription(subscriptionId: number): void
  • Parameters

    • subscriptionId: number

    Returns void

getSubscription

  • get the client subscription from Id

    Parameters

    • subscriptionId: number

    Returns ClientSubscription

getSubscriptionIds

  • getSubscriptionIds(): number[]
  • Returns number[]

hasSubscription

  • hasSubscription(subscriptionId: number): boolean
  • Parameters

    • subscriptionId: number

    Returns boolean

internalSendPublishRequest

  • internalSendPublishRequest(): void
  • Returns void

registerSubscription

  • Parameters

    Returns void

replenish_publish_request_queue

  • replenish_publish_request_queue(): void
  • Returns void

republish

  • republish(callback: () => void): void
  • Parameters

    • callback: () => void
        • (): void
        • Returns void

    Returns void

send_publish_request

  • send_publish_request(): void
  • method

    send_publish_request

    Returns void

suspend

  • suspend(suspendedState: boolean): void
  • Parameters

    • suspendedState: boolean

    Returns void

terminate

  • terminate(): void
  • Returns void

unregisterSubscription

  • unregisterSubscription(subscriptionId: number): void
  • method

    unregisterSubscription

    Parameters

    • subscriptionId: number

    Returns void

Generated using TypeDoc