Azure 服务总线队列 - 当消息位于队列中时，QueueClient.Receive() 返回空代理消息

我在 Azure 服务总线队列中有无法接收的消息。而且我没有得到任何关于问题出在哪里的指标。我认为这与消息大小有关。你可以从下面的代码中看到我正在使用OpenFileDialog。我正在选择 jpeg 图像，它们被发送到队列中。现在，当我发送小于 50KB 的小图像时，接收过程可以很好地显示它们，但超过 100KB 的大图像只是留在队列中。MSDN 说消息大小限制为 256KB，所以我不确定这里发生了什么。

我有两个班级。一个是SendToQueue，另一个是RecvFromQueue。这是代码。

using System;
using System.IO;
using System.Windows.Forms;
using Microsoft.ServiceBus;
using Microsoft.ServiceBus.Messaging;
using Microsoft.WindowsAzure;
namespace ServiceBusQueueApp
{
    public class SendToQueue
    {
        private const string c_testqueue = "TestQueue";
        [STAThreadAttribute]
        static void Main(string[] args)
        {
            // Configure Queue Settings
            QueueDescription qd = new QueueDescription(c_testqueue)
            {
                MaxSizeInMegabytes = 5120,
                DefaultMessageTimeToLive = new TimeSpan(1, 1, 0)
            };
            // Create a new Queue with custom settings
            string connectionString =
                CloudConfigurationManager.GetSetting("Microsoft.ServiceBus.ConnectionString");
            var namespaceManager =
                NamespaceManager.CreateFromConnectionString(connectionString);
            if (!namespaceManager.QueueExists(c_testqueue))
            {
                namespaceManager.CreateQueue(qd);
            }
            namespaceManager.DeleteQueue(qd.Path);
            namespaceManager.CreateQueue(qd);
            QueueClient client = QueueClient.CreateFromConnectionString(connectionString, c_testqueue);
            double maxSize = Math.Pow(2, 18);
            OpenFileDialog openFile = new OpenFileDialog();
            while (true)
            {
                if (openFile.ShowDialog() == DialogResult.Cancel)
                {
                    break;
                }
                var messageBodyStream = new FileStream(openFile.FileName, System.IO.FileMode.Open, FileAccess.Read, FileShare.ReadWrite);
                if (messageBodyStream.Length > maxSize)
                {
                    MessageBox.Show("File is larger than 256KB.");
                    continue;
                }
                BrokeredMessage msg =
                    new BrokeredMessage(messageBodyStream);
                msg.Properties["MyProperty"] = "Test Value";

                try
                {
                    //send msg to the queue
                    client.Send(msg);
                }
                catch (Exception exception)
                {
                    MessageBox.Show(exception.Message);
                    throw;
                }
            }
        }
    }
}

using System;
using System.Diagnostics;
using System.IO;
using System.Threading;
using System.Windows.Forms;
using Microsoft.ServiceBus;
using Microsoft.ServiceBus.Messaging;
using Microsoft.WindowsAzure;
namespace ServiceBusQueueApp
{
    class RecvFromQueue
    {
        private const string c_testqueue = "TestQueue";
        static void Main(string[] args)
        {
            // Create a new Queue with custom settings
            string connectionString =
                CloudConfigurationManager.GetSetting("Microsoft.ServiceBus.ConnectionString");
            var namespaceManager =
                NamespaceManager.CreateFromConnectionString(connectionString);
            if (!namespaceManager.QueueExists(c_testqueue))
            {
                MessageBox.Show("Queue does not exist.");
                throw new Exception("Queue does not exist.");
            }
            QueueClient client = QueueClient.CreateFromConnectionString(connectionString, c_testqueue);
            while (true)
            {
                BrokeredMessage message = client.Receive();
                if (message == null)
                {
                    continue;
                }
                try
                {
                    Stream fstream = message.GetBody<Stream>();
                    byte[] buffer = new byte[fstream.Length];
                    fstream.Read(buffer, 0, (int)fstream.Length);
                    File.WriteAllBytes(@"C:'users'roberthar'pictures'testpic.png", buffer);
                    fstream.Close();
                    Process paint = new Process();
                    paint.StartInfo.FileName = @"C:'Windows'System32'mspaint.exe";
                    paint.StartInfo.Arguments = @"C:'users'roberthar'pictures'testpic.png";
                    paint.Start();
                    Thread.Sleep(3000);
                    paint.Close();
                    // Remove message from queue
                    message.Complete();
                }
                catch (Exception exception)
                {
                    // Indicate a problem, unlock message in queue
                    message.Abandon();
                }
            }
        }
    }
}