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>