Options
All
  • Public
  • Public/Protected
  • All
Menu

Class MqttRelayProtocol

Hierarchy

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Properties

Protected _messageConverter

_messageConverter: MqttRelayMessageConverter

Protected _receiveStream

_receiveStream: Subject<Uint8Array>

Protected Optional lastMessage

lastMessage: MqttRelayMessagePayload

requestCounter

requestCounter: number = 1

sessionId

sessionId: number = 1

Static Protected TAG

TAG: string = "MqttRelayProtocol"

Accessors

clientOptions

  • get clientOptions(): IClientOptions

options

Methods

_abortConnect

  • _abortConnect(): void

_connect

  • _connect(options?: ComProtocolConnectOptions): Observable<any>

  • Parameters

    • Optional options: ComProtocolConnectOptions

    Returns Observable<any>

_disconnect

  • _disconnect(options?: ComProtocolDisconnectOptions): Observable<any>

  • Parameters

    • Optional options: ComProtocolDisconnectOptions

    Returns Observable<any>

connectToBroker

  • connectToBroker(): Promise<void>

  • Wait until the actual connection to the broker or time out.

    Returns Promise<void>

read

  • read(): Promise<Uint8Array>

  • Returns Promise<Uint8Array>

readOneValue

  • readOneValue(): Promise<Uint8Array>

setCredentials

  • setCredentials(credentials: object): this

  • Parameters

    • credentials: object
      • password: string
      • username: string

    Returns this

setDefaultConfig

  • setDefaultConfig(): void

setMessageConverter

subscribeToTopics

  • subscribeToTopics(topics?: string | string[]): Promise<ISubscriptionGrant[]>

  • Parameters

    • Optional topics: string | string[]

    Returns Promise<ISubscriptionGrant[]>

write

  • write(data: Uint8Array): Promise<Packet>

  • Parameters

    • data: Uint8Array

    Returns Promise<Packet>

Generated using TypeDoc