Options
All
  • Public
  • Public/Protected
  • All
Menu

Class PahoMQTTClient

Hierarchy

  • PahoMQTTClient

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

  • Parameters

    • configuration: MQTTConfiguration

    Returns PahoMQTTClient

Properties

Private client

client: Client

Private isConnectedSubject

isConnectedSubject: BehaviorSubject<boolean> = ...

Private isConnecting

isConnecting: boolean = false

Private subscribeOptions

subscribeOptions: SubscribeOptions = ...

Private subscribers

subscribers: {} = {}

Type declaration

  • [topic: string]: Subscriber<TopicAndPayload | string>[]

Private Optional useSSL

useSSL?: boolean

wildcardTopics

wildcardTopics: TopicWildcard[] = []

Methods

Private connectIfNeeded

  • connectIfNeeded(): void

  • Returns void

internalClient

  • internalClient(): Client

  • Returns Client

isConnected

  • isConnected(): BehaviorSubject<boolean>

  • Returns BehaviorSubject<boolean>

Private onConnect

  • onConnect(): void

  • Returns void

Private onConnectionError

  • onConnectionError(data?: { error?: ErrorWithInvocationContext; timeout?: number }): void

  • Parameters

    • Optional data: { error?: ErrorWithInvocationContext; timeout?: number }
      • Optional error?: ErrorWithInvocationContext
      • Optional timeout?: number

    Returns void

Private onMessageArrived

  • onMessageArrived(message: Message): void

  • Parameters

    • message: Message

    Returns void

publishMessage

  • publishMessage(topic: string, payload: string, qos: Qos, retained: boolean): void

  • Parameters

    • topic: string
    • payload: string
    • qos: Qos
    • retained: boolean

    Returns void

Private sendMessage

  • sendMessage(message: Message): void

  • Parameters

    • message: Message

    Returns void

Private sub2regex

  • sub2regex(topic: string): RegExp

  • Parameters

    • topic: string

    Returns RegExp

Private subscribe

  • subscribe(topic: string): void

  • Parameters

    • topic: string

    Returns void

topic

  • topic(pattern: string): Observable<string>

  • Parameters

    • pattern: string

    Returns Observable<string>

wildcardTopic

  • wildcardTopic(pattern: string): Observable<TopicAndPayload>

  • Parameters

    • pattern: string

    Returns Observable<TopicAndPayload>

Generated using TypeDoc