在两个不同队列上监听两种不同消息类型的RabbitMq监听器

dependencies:
  flutter:
    sdk: flutter
  dart_amqp: ^0.5.0  # 请使用最新版本

import 'package:flutter/material.dart';
import 'package:dart_amqp/dart_amqp.dart';

void main() => runApp(MyApp());

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('RabbitMQ Listener'),
        ),
        body: RabbitMQListener(),
      ),
    );
  }
}

class RabbitMQListener extends StatefulWidget {
  @override
  _RabbitMQListenerState createState() => _RabbitMQListenerState();
}

class _RabbitMQListenerState extends State<RabbitMQListener> {
  final Client client = Client();

  @override
  void initState() {
    super.initState();
    _setupListeners();
  }

  void _setupListeners() {
    // 监听第一个队列
    client.channel().then((Channel channel) {
      return channel.queue("queue1", durable: true);
    }).then((Queue queue) {
      queue.consume().listen((AmqpMessage message) {
        print("Received message from queue1: ${message.payloadAsString}");
        // 处理消息
      });
    });

    // 监听第二个队列
    client.channel().then((Channel channel) {
      return channel.queue("queue2", durable: true);
    }).then((Queue queue) {
      queue.consume().listen((AmqpMessage message) {
        print("Received message from queue2: ${message.payloadAsString}");
        // 处理消息
      });
    });
  }

  @override
  void dispose() {
    client.close();
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return Center(
      child: Text('Listening to RabbitMQ queues...'),
    );
  }
}