Hi,<br><br>Has anyone else run into this exception?<br><br>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 established connection was aborted by the software in your host machine. ---> System.Net.Sockets.SocketException: An established connection was aborted by the software in your host machine<br>
at System.Net.Sockets.Socket.Receive(Byte[] buffer, Int32 offset, Int32 size, SocketFlags socketFlags)<br> at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 size)<br> --- End of inner exception stack trace ---<br>
at RabbitMQ.Client.Impl.Frame.ReadFrom(NetworkBinaryReader reader)<br> at RabbitMQ.Client.Impl.SocketFrameHandler_0_9.ReadFrame()<br> at RabbitMQ.Client.Impl.ConnectionBase.MainLoopIteration()<br> at RabbitMQ.Client.Impl.ConnectionBase.MainLoop()<br>
<br><br>I declare my exchange and queue as such, I'm using the .net client.<br><br><pre style="font-family:Consolas;font-size:13;color:black;background:white;"><span style="color:#2b91af;">ConnectionFactory</span> factory = <span style="color:blue;">new</span> <span style="color:#2b91af;">ConnectionFactory</span>();
factory.UserName = settings.UserName;
factory.Password = settings.Password;
factory.HostName = settings.HostIp;
factory.VirtualHost = <span style="color:#a31515;">"data_loading"</span>;
factory.Port = <span style="color:#2b91af;">AmqpTcpEndpoint</span>.UseDefaultPort;
factory.Protocol = <span style="color:#2b91af;">Protocols</span>.AMQP_0_9_1;
<span style="color:blue;">this</span>.connection = factory.CreateConnection();
<span style="color:blue;">this</span>.model = <span style="color:blue;">this</span>.connection.CreateModel();
<span style="color:blue;">this</span>.model.ExchangeDeclare(MonitoringExchange, <span style="color:#2b91af;">ExchangeType</span>.Topic, <span style="color:blue;">true</span>, <span style="color:blue;">false</span>, <span style="color:blue;">null</span>);
<span style="color:blue;">this</span>.model.QueueDeclare(EventMessagesQueueName, <span style="color:blue;">true</span>, <span style="color:blue;">false</span>, <span style="color:blue;">false</span>, <span style="color:blue;">null</span>);
<span style="color:blue;">this</span>.model.QueueBind(EventMessagesQueueName, MonitoringExchange, <span style="color:blue;">this</span>.messageRoutingKey, <span style="color:blue;">null</span>);<br><br>and the publish that raises the exception is<br>
<br><span style="color:blue;">this</span>.model.BasicPublish(MonitoringExchange, <span style="color:blue;">this</span>.messageRoutingKey, <span style="color:blue;">null</span>, bytes);
<br>The connection is kept open from the start of the program until the exit, <br>which will probably be days, but it seems to happen after a few minutes. <br>I haven't timed it yet.<br><br>Do I have to recycle connections every so often?<br>
<br>Tim<br></pre><br>