korbacsk

I use this code after send and create listener consumer: ` String amqpMessageResponse; StreamSubscription streamSubscriptionMessage; Duration timeout = new Duration(seconds: 10); streamSubscriptionMessage = consumerForListen.listen( (AmqpMessage amqpMessage) { print('consumerForListen -> onMessage,...