Azure ServiceBus는 Client.Receive()에서 null을 반환합니다.

Question

하늘에서 설정 한 대기열에서 메시지를받는 데 문제가 있습니다. 이전에 같은 코드를 사용하여이 작업을 성공적으로 완료했지만 메시지를 가져 오려고하면 null이 표시됩니다. 하늘색 관리 콘솔에서 대기열을 볼 때 대기열에 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

이 문제의 해결 방법은 푸른 관리 포털의 버그로 인해 큐에 잘못된 메시지 수가 표시되거나 메시지에 플래그가 지정되어 읽을 수 없게됩니다. 다른 말로하면, 그것은 모든 일을 처리했기 때문에 새로운 메시지를 큐에 추가해야했습니다.

Answer 2

SubcriptionDescription.MessageCount에 표시되는 BrokeredMessages는 일반 메시지 일뿐만 아니라 $ DeadLetterQueue-sub 대기열에있는 메시지 수입니다.

이 코드 스 니펫을 사용하면 해당 하위 대기열에서 모든 메시지를 검색하고 세부 정보를 인쇄 할 수 있습니다. [topic] 및 [subscription]의 실제 이름을 다음과 같이 변경하십시오.

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(); 
      } 
     }