dart_mq 1.0.2

DartMQ is a message-queue system that facilitates communication between different components in the application.

example/main.dart

import 'package:dart_mq/dart_mq.dart';

import 'receiver.dart';
import 'sender.dart';

void main() async {
  MQClient.initialize();

  final sender = Sender();

  final receiver = Receiver()..listenToGreeting();

  sender.sendGreeting(greeting: 'Hello, World!');

  /// This line is because, well, the whole idea is built
  /// on asynchronous programming, so we need to wait for
  /// the stream to receive so that the listener can
  /// react appropriately.
  await Future.delayed(const Duration(milliseconds: 10));

  receiver.stopListening();
}