支持多Channel、key-value。
用法:
builder.Services.AddMemoryMQ();
生产者:
await _producer.ProduceAsync(channel, value);
await _producer.ProduceAsync(channel, key, value);
消费者:
consumer.OnMessage("test", async (message) =>
{
await Task.Run(() =>
{
Console.WriteLine($"Key: test, Value: {message.ToString()}");
}, stoppingToken);
});