stomp-dart-client-demo

main.dart

// dependencies:
//   stomp_dart_client: ^1.0.0

import 'dart:async';
import 'dart:convert';

import 'package:stomp_dart_client/stomp.dart';
import 'package:stomp_dart_client/stomp_config.dart';
import 'package:stomp_dart_client/stomp_frame.dart';

void onConnect(StompFrame frame) {

  print('Connected, start subscription to /topic/device/126/metric');

  stompClient.subscribe(
    destination: '/topic/device/126/metric',
    callback: (frame) {
      print('received message');
      Map<String, dynamic>? result = json.decode(frame.body!);
      print(result);
    },
  );
}

final stompClient = StompClient(
  config: StompConfig(
    url: 'wss://*******/websocket/ws',
    onConnect: onConnect,
    beforeConnect: () async {
      print('waiting to connect...');
      await Future.delayed(const Duration(milliseconds: 200));
      print('connecting...');
    },
    onWebSocketError: (dynamic error) => print(error.toString()),
    // stompConnectHeaders: {'Authorization': 'Bearer yourToken'},
    webSocketConnectHeaders: {'Cookie': '*******'},
  ),
);

void main() {
  stompClient.activate();
}