azureservicebus

    1熱度

    1回答

    我是Azure Service Bus的新手,想知道我是否可以將多個訂閱者加入隊列或主題?在兔子MQ中,我可以有1個發佈者的多個訂閱者。 我想要做的是,我正在使用CQRS,並且當事件處理時某些命令進入系統時,我想將它們推送到消息隊列中。 我希望2個訂戶能夠從該隊列中獲取消息,一個供我內部處理。另一個用於處理併發送到外部。

    3熱度

    1回答

    MS最近推出了Microsoft.Azure.ServiceBus命名空間。 https://github.com/Azure/azure-service-bus/blob/master/samples/readme.md 它非常適合新.NET標準框架(好像MS沒有足夠的半冗餘代碼基地) 我的問題是,如何更好地難道是在條款的表現? 我可以有把握地說,Microsoft.ServiceBus.Mes

    0熱度

    1回答

    我正在使用azure sdk和其他客戶端將事件發送到IoT中心。 我不得不使用物聯網集線器路由功能,因此我加入除了屬性主要有效載荷發送到IotHub 案例1日前:發送數據使用Azure的SDK 事件模型 RealTimeMachineData realTimeData = new RealTimeMachineData(); realTimeData.Date = DateTime.UtcNow

    0熱度

    1回答

    我訂閱了使用Azure Service Bus中的過濾器的主題並使用Python 3.x開發,當我等待發送到該主題的信息(通過過濾器的信息)時,我無法接收它。 我需要創建一個守護進程總是聽,當我收到信息,我把它發送到我的應用程序的內部服務,所以接收機在一個線程中運行循環While True 裏面的代碼我用它來接收消息如下: while True: msg = bus_service.re

    0熱度

    1回答

    我遇到Azure服務總線輸出綁定問題,我不確定如何繼續。我沒有找到類似的問題,所以我很抱歉,如果這是重複的。 我想使用本地VS 2017開發過程,所以應該自動生成的function.json綁定。函數簽名如下: [FunctionName("RequestNewPaladinInvitation")] public static HttpResponseMessage Run(

    1熱度

    1回答

    我知道我可以註冊一個新的「服務端點」在MS CRM和使用,將消息發送到Azure的服務總線,但這個...是不是真的是我在找什麼。上述方法最終發送一個序列號爲RemoteExecutionContext。 在我的情況,我想有過什麼樣的服務總線的消息將包含完全控制。這意味着序列化我自己的類。 我試過使用WindowsAzure.ServiceBus塊(和ILmerging新的DLL),但這隻適用於非沙

    0熱度

    1回答

    我有一個消息泵看起來像這樣: public class MessagePump<T> where T : class { public async Task Run(string inQueue, IMessageProcessor<T> processor, CancellationToken cancellationToken) { var co

    0熱度

    1回答

    我發現我可以使用Azure中繼在雲服務和本地服務之間建立雙向連接。但是我無法在azure網站上找到有關「Azure中繼支持多少個混合連接?」這個問題的任何信息「」。有人知道嗎?謝謝。

    0熱度

    1回答

    使用隊列客戶端創建輔助角色時的模板代碼提供了消息泵實現。代碼中有一條評論: // Initiates the message pump and callback is invoked for each message that is received, calling close on the client will stop the pump. sourceClient.OnMessage(r

    0熱度

    2回答

    爲了記錄目的,我希望獲得給定訂閱客戶端的Azure服務總線訂閱的消息數。唯一的examples我發現使用NamespaceManager,但這似乎有點多餘,因爲我已經有一個SubscriptionClient。有沒有辦法直接從客戶端到SubscriptionDescription? FWIW,我試圖通過名字空間管理器使用的彎路,但我得到了它拋出一個401未經授權錯誤: int GetMessage