MqttOverWSProvider | amplify-js

Hierarchy

AbstractPubSubProvider<MqttProviderOptions>
- MqttOverWSProvider
  - AWSIoTProvider

Implements

PubSubProvider

Index

Constructors

constructor

Properties

Accessors

Methods

Constructors

constructor

new MqttOverWSProvider(options?: MqttProviderOptions): MqttOverWSProvider

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

Properties

Protected _clientIdObservers

_clientIdObservers: Map<string, Set<PubSubContentObserver>> = new Map()

Protected _topicObservers

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

Accessors

Protected clientId

clientId:

Protected clientsQueue

clientsQueue:

Protected endpoint

endpoint:

Protected isSSLEnabled

isSSLEnabled:

Protected options

options:

Methods

configure

configure(config: MqttProviderOptions): MqttProviderOptions

Inherited from AbstractPubSubProvider.configure
- Defined in packages/pubsub/src/Providers/PubSubProvider.ts:22
Parameters
- config: MqttProviderOptions
Returns MqttProviderOptions

Protected connect

connect(clientId: string, options?: MqttProviderOptions): Promise<PahoClient | undefined>

- Defined in packages/pubsub/src/Providers/MqttOverWSProvider.ts:231
Parameters
- clientId: string
- Default value options: MqttProviderOptions = {}
Returns Promise<PahoClient | undefined>

Protected disconnect

disconnect(clientId: string): Promise<void>

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

getCategory

getCategory(): string

Implementation of PubSubProvider.getCategory

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

getProviderName

getProviderName(): string

Implementation of PubSubProvider.getProviderName

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

newClient

newClient(__namedParameters: object): Promise<PahoClient>

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

onDisconnect

onDisconnect(__namedParameters: object): void

- Defined in packages/pubsub/src/Providers/MqttOverWSProvider.ts:158
Parameters
- __namedParameters: object
  - args: args
  - clientId: string
  - errorCode: number
Returns void

publish

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

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

subscribe

subscribe(topics: string[] | string, options?: MqttProviderOptions): Observable<PubSubContent>

Implementation of PubSubProvider.subscribe

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