Azure ServiceBus возвращает ноль в Client.Receive ()

Question

У меня проблема с получением сообщений из очереди, которую я настроил в Azure. Я сделал это успешно, используя тот же код раньше, но теперь я просто получаю нулевое значение, когда я пытаюсь получить сообщения. Когда я просматриваю очередь в консоли управления Azure, я ясно вижу, что очередь содержит 5 сообщений.

Вот код:

ServiceBus SB = new ServiceBus();
Microsoft.ServiceBus.Messaging.BrokeredMessage message;
while (true)
{
    message = SB.ReceiveMessage("orders");
    if (message == null)
    {
        break;
    }
    Procurement.Order order = message.GetBody<Procurement.Order>();
    order.id = Guid.NewGuid().ToString();
    order.remindercount = 0;

    using (DbManager db = new DbManager())
    {
        if (db.SetSpCommand("CreateOrderHead",
            db.Parameter("@companyId", order.companyId),
            db.Parameter("@orderId", order.orderId),
            db.Parameter("@suppliercode", order.suppliercode),
            db.Parameter("@supplierorderId", order.supplierorderId),
            db.Parameter("@orderdate", order.orderdate),
            db.Parameter("@desireddate", order.desireddate),
            db.Parameter("@ordertext", order.ordertext),
            db.Parameter("@name", order.name),
            db.Parameter("@street", order.street),
            db.Parameter("@zip", order.zip),
            db.Parameter("@city", order.city),
            db.Parameter("@country", order.country),
            db.Parameter("@countrycode", order.countrycode),
            db.Parameter("@deliveryterms", order.deliveryterms),
            db.Parameter("@reference", order.reference),
            db.Parameter("@deliveryinstruction", order.deliveryinstruction),
            db.Parameter("@id", order.id),
            db.Parameter("@partycode", order.partyCode)
            ).ExecuteNonQuery() == 1)
        {
            message.Complete();
            message = null;
        }

        db.SetSpCommand("DeleteOrderRows",
            db.Parameter("@orderid", order.orderId),
            db.Parameter("@companyId", order.companyId)
            ).ExecuteNonQuery();

        foreach (Procurement.Orderrow r in order.Orderrows)
        {
            db.SetSpCommand("CreateOrderRow",
            db.Parameter("@companyId", r.companyId),
            db.Parameter("@orderId", r.orderId),
            db.Parameter("@orderrowId", r.orderrowId),
            db.Parameter("@itemId", r.itemId),
            db.Parameter("@itemdesc", r.itemdesc),
            db.Parameter("@orderqty", r.orderqty),
            db.Parameter("@desireddate", r.desireddate),
            db.Parameter("@rowtext", r.rowtext),
            db.Parameter("@supplieritemId", r.supplieritemId),
            db.Parameter("@unit", r.unit),
            db.Parameter("@id", order.id),
            db.Parameter("@unitprice", r.unitprice),
            db.Parameter("@rowprice", r.rowprice)
            ).ExecuteNonQuery();
        }
    }
}
Thread.Sleep(new TimeSpan(0, 1, 0));

А это класс ServiceBus:

public class ServiceBus
{
    TokenProvider TokenProvider;
    MessagingFactory Factory;

    public ServiceBus()
    {
        TokenProvider = TokenProvider.CreateSharedSecretTokenProvider(GetIssuerName(), GetSecret());
        Factory = MessagingFactory.Create(
            GetURINameSpace(),
            TokenProvider
            );
    }

    public void SendMessage(string queue, BrokeredMessage message)
    {
        var client = Factory.CreateQueueClient(queue);
        client.Send(message);
    }

    public BrokeredMessage ReceiveMessage(string queue)
    {
        var client = Factory.CreateQueueClient(queue, ReceiveMode.ReceiveAndDelete);
        BrokeredMessage message = client.Receive();
        return message;
    }

    private static Uri GetURINameSpace()
    {
        return ServiceBusEnvironment.CreateServiceUri("sb", GetNamespace(), string.Empty);
    }

    private static string GetNamespace()
    {
        return "Namespace i have verified its the right one";
    }

    private static string GetIssuerName()
    {
        return "Issuer i have verified its the right one";
    }

    private static string GetSecret()
    {
        return "Key i have verified its the right one";
    }
}

Я думаю, это должно быть довольно просто, но я не могу понять, что я делаю не так. Это, наверное, что-то маленькое, чего мне не хватает ...

В любом случае, спасибо заранее!

Answer 1

Те BrokeredMessages, которые вы видите в SubcriptionDescription.MessageCount, являются не только обычными сообщениями, но и счетчиком сообщений в очереди $ DeadLetterQueue-sub !!!

Используйте этот фрагмент кода, чтобы извлечь все сообщения из этой очереди и распечатать их детали. Переименуйте [тему] и [подписку] в ваши фактические:

MessagingFactory msgFactory = MessagingFactory.Create(_uri, _tokenProvider);
        MessageReceiver msgReceiver = msgFactory.CreateMessageReceiver("[topic]/subscriptions/[subscription]/$DeadLetterQueue", ReceiveMode.PeekLock);

        while (true)
        {
            BrokeredMessage msg = msgReceiver.Receive();

            if (msg != null)
            {
                Console.WriteLine("Deadlettered message.");

                Console.WriteLine("MessageId:                  {0}", msg.MessageId);
                Console.WriteLine("DeliveryCount:              {0}", msg.DeliveryCount);
                Console.WriteLine("EnqueuedTimeUtc:            {0}", msg.EnqueuedTimeUtc);
                Console.WriteLine("Size:                       {0} bytes", msg.Size);
                Console.WriteLine("DeadLetterReason:           {0}",
                    msg.Properties["DeadLetterReason"]);
                Console.WriteLine("DeadLetterErrorDescription: {0}",
                    msg.Properties["DeadLetterErrorDescription"]);
                Console.WriteLine();
                msg.Complete();
            }
        }

Answer 2

Решением этой проблемы была либо ошибка в Azure Management-Portal, заставляющая его показывать неверное количество сообщений в очереди, либо сообщения каким-то образом помечались, чтобы они не читались. Другими словами, это работало все время, мне просто нужно было добавить несколько новых сообщений в очередь.