[rabbitmq-discuss] Possible bug when disposing connections in .NET client 2.7.0/1

Dave Stevens daverstevens at gmail.com
Wed Dec 28 15:43:13 GMT 2011


I am getting the following exception when disposing a connection. I
had previously noticed this when going from RabbitMQ Client 2.5.1 to
2.7.0 which caused me to back out the update. I ended up going to
2.7.1 because I thought I found a shutdown issue in my own code. The
exception did not present itself again until I started testing some
reconnect logic. I first noticed it again after simply pulling the
plug on my network.

System.ObjectDisposedException: Cannot access a disposed object.
Object name: 'System.Net.Sockets.Socket'.
at System.Net.Sockets.Socket.SetSocketOption(SocketOptionLevel
optionLevel, SocketOptionName optionName, Object optionValue)
at RabbitMQ.Client.Impl.SocketFrameHandler_0_9.Close()
at RabbitMQ.Client.Impl.ConnectionBase.FinishClose()
at RabbitMQ.Client.Impl.ConnectionBase.HeartbeatWriteLoop()
at System.Threading.ThreadHelper.ThreadStart_Context(Object state)
at System.Threading.ExecutionContext.runTryCode(Object userData)
at
System.Runtime.CompilerServices.RuntimeHelpers.ExecuteCodeWithGuaranteedCleanup(TryCode
code, CleanupCode backoutCode, Object userData)
at System.Threading.ExecutionContext.RunInternal(ExecutionContext
executionContext, ContextCallback callback, Object state)
at System.Threading.ExecutionContext.Run(ExecutionContext
executionContext, ContextCallback callback, Object state, Boolean
ignoreSyncCtx)
at System.Threading.ExecutionContext.Run(ExecutionContext
executionContext, ContextCallback callback, Object state)
at System.Threading.ThreadHelper.ThreadStart()

This code is reproducible consistently with the following:

using System;
using System.Threading;
using NUnit.Framework;
using RabbitMQ.Client;
using RabbitMQ.Client.Framing.v0_9;

namespace BT.ThirdPartyProxy.Functional.Test.FunctionalTests
{
    [TestFixture]
    public class TestingObjectDispositionException
    {
        [Test(Description = "ObjectDispositionException")]
        public void TestFail()
        {
            var cf = new ConnectionFactory
                         {
                             HostName = INSERT_IP_HERE,
                             Port = 5672,
                             RequestedHeartbeat = 2
                         };
            using (var connection = cf.CreateConnection())
            using (var model = connection.CreateModel())
            {
                Thread.Sleep(TimeSpan.FromSeconds(1));
                model.Close(Constants.ReplySuccess, "Goodbye");
                connection.Close(Constants.ReplySuccess, "Goodbye");
                Thread.Sleep(TimeSpan.FromSeconds(1));
            }
        }
    }
}


I am using RabbitMQ.Client.dll 2.7.1.0 in .NET 4.0 app on Windows
server 2003 going against RabbitMQ 2.7.0 running on Ubuntu.

Status of node rabbit at xxx ...
[{pid,1344},
 {running_applications,
     [{rabbitmq_management,"RabbitMQ Management Console","2.7.0"},
      {rabbitmq_management_agent,"RabbitMQ Management Agent","2.7.0"},
      {amqp_client,"RabbitMQ AMQP Client","2.7.0"},
      {rabbit,"RabbitMQ","2.7.0"},
      {os_mon,"CPO  CXC 138 46","2.2.5"},
      {sasl,"SASL  CXC 138 11","2.1.9.3"},
      {rabbitmq_mochiweb,"RabbitMQ Mochiweb Embedding","2.7.0"},
      {webmachine,"webmachine","1.7.0-rmq2.7.0-hg"},
      {mochiweb,"MochiMedia Web Server","1.3-rmq2.7.0-git"},
      {inets,"INETS  CXC 138 49","5.5.2"},
      {mnesia,"MNESIA  CXC 138 12","4.4.17"},
      {stdlib,"ERTS  CXC 138 10","1.17.3"},
      {kernel,"ERTS  CXC 138 10","2.14.3"}]},
 {os,{unix,linux}},
 {erlang_version,
     "Erlang R14B02 (erts-5.8.3) [source] [64-bit] [smp:8:8] [rq:8]
[async-threads:30] [kernel-poll:true]\n"},
 {memory,
     [{total,31177024},
      {processes,11828776},
      {processes_used,11772888},
      {system,19348248},
      {atom,1355273},
      {atom_used,1339382},
      {binary,84928},
      {code,14547474},
      {ets,1099944}]},
 {vm_memory_high_watermark,0.39999999995232727},
 {vm_memory_limit,5034326425}]
...done.


More information about the rabbitmq-discuss mailing list