[snip]
  private MessageQueue OpenQueue()
  {
    if (queue != null)
    {
      return queue;
    }
    lock (SyncRoot)
    {
      if (queue != null)
      {
        return queue;
      }
      if (!MessageQueue.Exists(QueueName))
      {
        log.DebugFormat("Creating MSMQ [{0}]", QueueName);
        MessageQueue val = MessageQueue.Create(QueueName);
        try
        {
          ConfigureUsers(val);
        }
        finally
        {
          ((IDisposable)val)?.Dispose();
        }
      }
      log.DebugFormat("Opening MSMQ [{0}]", QueueName);
      MessageQueue val2 = null;
      try
      {
        bool messageSigningEnabled = CollectorSettings.Instance.MessageSigningEnabled;
        val2 = new MessageQueue(QueueName);
        val2.set_Formatter((IMessageFormatter)(object)new CompressedMessageFormatter((IMessageFormatter)new BinaryMessageFormatter(), messageSigningEnabled ? new DataSignature() : null));
        val2.get_MessageReadPropertyFilter().set_ArrivedTime(true);
        if (messageSigningEnabled)
        {
          val2.get_MessageReadPropertyFilter().set_Extension(true);
        }
        if (val2.get_MaximumQueueSize() != maximumQueueSize)
        {
          val2.set_MaximumQueueSize(maximumQueueSize);
        }
        queue = val2;
      }
      catch (Exception exception)
      {
        log.Error("Failed to initialize queue " + QueueName, exception);
        if (val2 != null)
        {
          ((Component)val2).Dispose();
        }
        throw;
      }
      return val2;
    }
  }
[snip]

[snip]
  public object Read(Message message)
  {
    if (message == null)
    {
      throw new ArgumentNullException("message");
    }
    if (dataSignature != null)
    {
      message.get_BodyStream().Position = 0L;
      if (!dataSignature.VerifyData(message.get_BodyStream(), message.get_Extension()))
      {
        throw new VerificationException("Invalid data signature");
      }
    }
    byte[] array = new byte[compressHeader.Length];
    message.get_BodyStream().Position = 0L;
    message.get_BodyStream().Read(array, 0, array.Length);
    if (compressHeader.SequenceEqual(array))
    {
      message.get_BodyStream().Seek(array.LongLength, SeekOrigin.Begin);
      DeflateStream val = new DeflateStream(message.get_BodyStream(), (CompressionMode)0);
      try
      {
        Message val2 = new Message();
        val2.set_BodyType(message.get_BodyType());
        ((Stream)(object)val).CopyTo(val2.get_BodyStream());
        message.set_BodyStream(val2.get_BodyStream());
      }
      finally
      {
        ((IDisposable)val)?.Dispose();
      }
    }
    message.get_BodyStream().Position = 0L;
    return baseFormatter.Read(message);
  }
[snip]

[snip]
        /// <include file='doc\BinaryMessageFormatter.uex' path='docs/doc[@for="BinaryMessageFormatter.Read"]/*' />
        /// <devdoc>
        ///    This method is used to read the contents from the given message
        ///     and create an object.
        /// </devdoc>
        public object Read(Message message)
        {
            if (message == null)
                throw new ArgumentNullException("message");

            int variantType = message.BodyType;
            if (variantType == VT_BINARY_OBJECT)
            {
                Stream stream = message.BodyStream;
                return formatter.Deserialize(stream);
            }

            throw new InvalidOperationException(Res.GetString(Res.InvalidTypeDeserialization));
        }
[snip]