aws-iot-mqtt-broker

Usage:

Installation

npm i @mhlabs/aws-iot-ws-broker

Connecting (TypeScript)

import AwsIot, { IotEvent } from '@mhlabs/aws-iot-ws-broker';

// credentials could be e.g. from Cognito Identity Pool
const creds: CognitoIdentityCredentials = createCredentials();
this.websocket = new AwsIot(creds, !environment.production);

Subscribe to topic:

New in this version is that subscribe() returns an Observable and therefor needs to be subscribed to. The Observable with emit and complete when the topic has been subscribed to.

this.websocket.subscribe('your/topic').subscribe(topic => console.log(`${topic} has been subscribed to`));

Send message

this.websocket.send('your/topic', message);

Handle message:

this.websocket.events.pipe(filter(event => event.type === IotEventType.Message)).subscribe(event => console.log(`Message on topic ${event.topic}:`, event.message));