|
|
@@ -146,7 +146,7 @@ namespace MySystem
|
|
|
var consumer = new EventingBasicConsumer(channel);
|
|
|
consumer.Received += (a, e) =>
|
|
|
{
|
|
|
- Library.Utils.WriteLog(Encoding.Default.GetString(e.Body.ToArray()), "接收到的MQ消息");
|
|
|
+ Utils.WriteLog(Encoding.Default.GetString(e.Body.ToArray()), "接收到的MQ消息");
|
|
|
channel.BasicAck(e.DeliveryTag, true); //收到回复后,RabbitMQ会直接在队列中删除这条消息
|
|
|
};
|
|
|
channel.BasicConsume(QueueName, false, consumer);
|