草庐IT

AlreadyClosedException

全部标签

关于.net core:RabbitMQ Consumer : AlreadyClosedException

RabbitMQConsumer:AlreadyClosedException我有一个简单的RabbitMQ发布者和消费者代码,如下所示。首先,我在My_Tasks队列中创建了10条不同的消息。当我尝试逐个获取这些消息并且autoAck标志为false时,我可以读取第一条消息,但无法将确认发送到RabbitMQ服务器。我收到下面写的错误;出版商;123456789101112131415varqName="My_Tasks";using(varconnection=factory.CreateConnection()){  using(varchannel=connection.CreateM

关于.net core:RabbitMQ Consumer : AlreadyClosedException

RabbitMQConsumer:AlreadyClosedException我有一个简单的RabbitMQ发布者和消费者代码,如下所示。首先,我在My_Tasks队列中创建了10条不同的消息。当我尝试逐个获取这些消息并且autoAck标志为false时,我可以读取第一条消息,但无法将确认发送到RabbitMQ服务器。我收到下面写的错误;出版商;123456789101112131415varqName="My_Tasks";using(varconnection=factory.CreateConnection()){  using(varchannel=connection.CreateM