Class MqttOverWSProvider

Hierarchy

AbstractPubSubProvider
- MqttOverWSProvider
  - AWSAppSyncProvider
  - AWSIoTProvider

Implements

any

Index

Constructors

constructor

Properties

_topicObservers

Accessors

Methods

Constructors

constructor

new MqttOverWSProvider(options?: MqttProvidertOptions): MqttOverWSProvider

Overrides AbstractPubSubProvider.constructor
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:55
Parameters
- Default value options: MqttProvidertOptions = {}
Returns MqttOverWSProvider

Properties

Protected _topicObservers

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

Accessors

Protected clientId

get clientId(): any

- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:61
Returns any

Protected clientsQueue

get clientsQueue(): ClientsQueue

- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:65
Returns ClientsQueue

Protected endpoint

get endpoint(): any

- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:63
Returns any

Protected options

get options(): ProvidertOptions

Inherited from AbstractPubSubProvider.options
- Defined in pubsub/src/Providers/PubSubProvider.ts:39
Returns ProvidertOptions

Methods

configure

configure(config?: ProvidertOptions): ProvidertOptions

Inherited from AbstractPubSubProvider.configure
- Defined in pubsub/src/Providers/PubSubProvider.ts:27
Parameters
- Default value config: ProvidertOptions = {}
Returns ProvidertOptions

Protected connect

connect(clientId: string, options?: MqttProvidertOptions): Promise<Paho.Client>

- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:101
Parameters
- clientId: string
- Default value options: MqttProvidertOptions = {}
Returns Promise<Paho.Client>

Protected disconnect

disconnect(clientId: string): Promise<void>

- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:105
Parameters
- clientId: string
Returns Promise<void>

getCategory

getCategory(): string

Inherited from AbstractPubSubProvider.getCategory
- Defined in pubsub/src/Providers/PubSubProvider.ts:35
Returns string

getProviderName

getProviderName(): string

Overrides AbstractPubSubProvider.getProviderName
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:69
Returns string

Protected getTopicForValue

getTopicForValue(value: any): any

- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:67
Parameters
- value: any
Returns any

newClient

newClient(__namedParameters: object): Promise<Paho.Client>

Overrides AbstractPubSubProvider.newClient
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:77
Parameters
- __namedParameters: object
  - clientId: string
  - url: string
Returns Promise<Paho.Client>

onDisconnect

onDisconnect(__namedParameters: object): void

- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:71
Parameters
- __namedParameters: object
  - args: args
  - clientId: any
  - errorCode: any
Returns void

publish

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

Overrides AbstractPubSubProvider.publish
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:114
Parameters
- topics: string[] | string
- msg: any
Returns Promise<void>

subscribe

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

Overrides AbstractPubSubProvider.subscribe
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:143
Parameters
- topics: string[] | string
- Default value options: MqttProvidertOptions = {}
Returns Observable<any>