brokeredmessage

0熱度

1回答

我試圖使用基於消息屬性的消息路由將設備消息路由到IotHub。我將它們路由到服務總線主題。但是，我看到的是，儘管發送給IoTHub之前設置 Microsoft.Azure.Devices.Client.Message 類的ContentType屬性，相同的屬性是沒有看到填充的消息路由成功後發出的Brokered消息。有什麼我在這裏失蹤？代碼在設備側： BrokeredMessage msgFr

1熱度

2回答

使用SendBatchAsync方法向服務總線發送1000箇中介消息

我有一個應用程序，其中數據從SQL DB中獲取並作爲中介消息發送到服務總線。這些步驟如下：從DB 數據取出（在1000批次）轉換成牽線消息，並添加到列表中的數據的每一行。 1000個代理消息的列表使用SendBatchAsync方法發送到服務總線。這是我第三步面對的問題。這是代碼爲： public async Task SendMessagesAsync(List<BrokeredMessag

0熱度

1回答

（Azure）BrokeredMessage.GetBody <xxx>

我試圖把一個'通用'訂戶放在一起，我可以（重新）使用Azure ServiceBus。但我堅持如下; 我的代碼曾經剝離過非必要部分，看起來像這樣。 Subscribing.Client.OnMessage((recdMessage => { var msgBody = recdMessage.GetBody<myClass>(); }, options); 我希望我的msgBo

5熱度

3回答

BrokeredMessage配置

我在編輯BrokeredMessage時遇到了麻煩。簡單的代碼，就像預期： private void OnMessageArrived(BrokeredMessage message) { var myObj= message.GetBody<MyObject>(); //do things with myObj message.Complete();

0熱度

1回答

從Azure服務總線訂閱中獲取所有代理消息

我正在使用Azure服務總線訂閱和主題發送訂單和獲取訂單。我們有一個Windows應用程序，它使用來自Azure服務總線訂閱的Web API來下訂單。假設用戶登錄並獲得5個訂單。如果用戶從Windows應用程序註銷，然後我們解鎖來自天藍色服務總線的消息。並且如果用戶在5分鐘或更少時間後再次登錄，那麼我們沒有從天藍色的服務總線獲取所有訂單。它有時像3或4。任何人都可以幫助我解決這個問題，爲什麼我

0熱度

1回答

Azure服務總線隊列消息處理

所以我有一個azure函數作爲調用內部託管的API的隊列觸發器。關於如何處理由於除有毒以外的問題而無法處理的消息，似乎沒有在線確定的答案。一個例子：接收我的消息和功能試圖調用API。消息有效負載是正確的，可以處理，但無論什麼原因，API /服務都會關閉（這段時間可能會超過10分鐘）。目前發生的事情是消息傳遞計數達到其最大值（10），然後被推送到死信隊列中，而這又會發生在每個消息之後。我需要

3熱度

2回答

在本地使用Azure服務總線

我正在使用Azure服務總線主題和訂閱。它被用來在整個應用程序中發送控制消息。消息偵聽器（訂閱者）正在工作角色中運行，他們正在拾取消息並處理請求。即使有多個偵聽器同時運行，總線中的每條消息也只能被拾取一次。使用服務總線沒有問題;但是我們在調試/測試本地應用程序時遇到了一些問題。我們有2條服務總線，一條用於雲端，一條用於本地調試。現在，如果多個人同時調試應用程序，則該消息僅由系統中的一個（隨機）選

0熱度

2回答

如何在azureservicebus中查看並刪除deadletter的郵件

我創建了一個蔚藍的服務總線主題應用程序，它可以查看deadletter中的所有消息。一些特定的消息（特別是messageid）我偷看需要從死信隊列中刪除。請爲實現這個提供幫助。非常感謝

0熱度

2回答

BrokeredMessage Azure ServiceBus的虛假投遞和接收

我已經創建了BrokeredMessage的一個實例，並且希望圍繞它的deliverycount測試我的代碼與隊列的最大投遞計數。我不想站立一個真正的隊列來發送和接收消息，但deliverycount屬性在消息傳遞之前不會被初始化。我怎麼能僞造這個？

1熱度

1回答

C＃服務總線多個偵聽器都收到相同的消息（BrokeredMessage）

我曾經使用RabbitMQ作爲消息傳遞平臺，我從來沒有遇到過任何問題 - 不幸的是，最近我們將基礎架構遷移到了Azure，提供RabbitMQ服務器，所以我想過嘗試Service Bus擴展。我有一個作家和多個讀者。目前，讀者將分別讀取不同的消息（消息競爭模式 - 例如對負載平衡有益）。我想要的是，所有的讀者都得到相同的信息並自行處理。讀者（S）： string connectionKey