import { Component } from '@angular/core'; import { Client, Message } from 'mqtt';
@Component({ selector: 'app-root', templateUrl: './app.component.html', styleUrls: ['./app.component.css'] }) export class AppComponent { title = 'mqtt-test-app'; client: Client; messages: Message[] = [];
constructor() { this.client = new Client('test.mosquitto.org', 8080, '', ''); this.client.onConnect = (ack) => { console.log('onConnect', ack); this.client.subscribe('/test'); }; this.client.onMessage = (topic, payload) => { console.log('onMessage', topic, payload); this.messages.push({ topic, payload }); }; this.client.connect(); } }