Class AWSIoTProvider

Hierarchy

MqttOverWSProvider
- AWSIoTProvider

Implements

any

Index

Constructors

constructor

Properties

_topicObservers

Accessors

Methods

Constructors

constructor

new AWSIoTProvider(options?: MqttProvidertOptions): AWSIoTProvider

Inherited from MqttOverWSProvider.constructor

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

Properties

Protected _topicObservers

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

Accessors

Protected clientId

get clientId(): any

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

Protected clientsQueue

get clientsQueue(): ClientsQueue

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

Protected endpoint

get endpoint(): Promise<any>

Overrides MqttOverWSProvider.endpoint
- Defined in pubsub/src/Providers/AWSIotProvider.ts:24
Returns Promise<any>

Protected options

get options(): ProvidertOptions

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

Protected region

get region(): any

- Defined in pubsub/src/Providers/AWSIotProvider.ts:20
Returns any

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>

Inherited from MqttOverWSProvider.connect
- 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>

Inherited from MqttOverWSProvider.disconnect
- 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 MqttOverWSProvider.getProviderName
- Defined in pubsub/src/Providers/AWSIotProvider.ts:22
Returns string

Protected getTopicForValue

getTopicForValue(value: any): any

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

newClient

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

Inherited from MqttOverWSProvider.newClient

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

Inherited from MqttOverWSProvider.onDisconnect
- 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>

Inherited from MqttOverWSProvider.publish

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>

Inherited from MqttOverWSProvider.subscribe

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