RabbitMQ.Client.Exceptions.OperationInterruptedException: 'The AMQP operation was interrupted: AMQP close-reason, initiated by Library, code=541, text='Unexpected Exception', classId=0, methodId=0, cause=System.IO.IOException: Unable to read data from the transport connection: An existing connection was forcibly closed by the remote host..
---> System.Net.Sockets.SocketException (10054): An existing connection was forcibly closed by the remote host.
at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 count)
--- End of inner exception stack trace ---
at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 count)
at System.IO.BufferedStream.ReadByteSlow()
at RabbitMQ.Client.Impl.InboundFrame.ReadFrom(Stream reader, Byte[] frameHeaderBuffer, ArrayPool`1 pool, UInt32 maxMessageSize)
at RabbitMQ.Client.Impl.SocketFrameHandler.ReadFrame()
at RabbitMQ.Client.Framing.Impl.Connection.MainLoopIteration()
at RabbitMQ.Client.Framing.Impl.Connection.MainLoop()'
public class RabbitMqListener : BackgroundService
{
private IConnection _connection;
private IModel _channel;
public RabbitMqListener()
{
var factory = new ConnectionFactory() { HostName = "localhost", /*Port= 15672,*/ /*AutomaticRecoveryEnabled = true, UserName = "guest", Password="guest"*/ };
_connection = factory.CreateConnection();
_channel = _connection.CreateModel();
на последней строке исключение, помогшите разобраться
я совсем новичёк — установил плагин для веб на
http://localhost:15672/ и он работает
что ещё нужно?