Class NotificationStore

constructor

• new NotificationStore(main: MainStore): NotificationStore

• Parameters

  • main: MainStore

  Returns NotificationStore

connected

listeners

main

OptionalmqttClient

reconnectAttempts

OptionalreconnectHandler

subscribedTopics

subscribeQueue

topicStage

• get topicStage(): string

• Returns string

connect

• connect(credentials?: IotCredentials): Promise<void>

• Parameters

  • Optionalcredentials: IotCredentials

  Returns Promise<void>

connectWithCredentials

• connectWithCredentials(data: IotCredentials): void

• Parameters

  • data: IotCredentials

  Returns void

executeListeners

• executeListeners(subscriptions: Subscription[], message: unknown): void

• Parameters

  • subscriptions: Subscription[]
  • message: unknown

  Returns void

getCredentials

• getCredentials(): Promise<undefined | IotCredentials>

• Returns Promise<undefined | IotCredentials>

isConnected

• isConnected(): boolean

• Returns boolean

resolveSubscriptionQueue

• resolveSubscriptionQueue(): void

• Returns void

resolveSubscriptions

• resolveSubscriptions(): void

• Returns void

setReconnectHandler

• setReconnectHandler(handler: () => void): void

• Parameters

  • handler: () => void

  Returns void

subscribe

• subscribe(
      topicPostfix: string,
      onMessage: (data: any) => void,
      reference?: string,
  ): undefined | string

• Parameters

  • topicPostfix: string
  • onMessage: (data: any) => void
  • Optionalreference: string

  Returns undefined | string

unsubscribe

• unsubscribe(topicPostfix: string, reference: string): void

• Parameters

  • topicPostfix: string
  • reference: string

  Returns void