Options
All
  • Public
  • Public/Protected
  • All
Menu

Hierarchy

Implements

  • any

Index

Constructors

constructor

Properties

Protected _topicObservers

_topicObservers: Map<string, Set<SubscriptionObserver<any>>> = new Map()

Accessors

Protected clientId

clientId:

Protected clientsQueue

clientsQueue:

Protected endpoint

endpoint:

Protected options

options:

Methods

configure

Protected connect

Protected disconnect

  • disconnect(clientId: string): Promise<void>

getCategory

  • getCategory(): string

getProviderName

  • getProviderName(): string

Protected getTopicForValue

  • getTopicForValue(value: any): any

newClient

  • newClient(__namedParameters: object): Promise<any>

onDisconnect

  • onDisconnect(__namedParameters: object): void

publish

  • publish(topics: string[] | string, msg: any, options?: any): Promise<void>

subscribe

  • subscribe(topics: string[] | string, options?: any): Observable<any>