azure-servicebus-queues

    1熱度

    2回答

    我開發蔚藍2個WebJobs:這是訂閱使用同一主題的ServiceBusTrigger一個將使用主題可以將消息在服務總線隊列和另一個。 的消息被正確地發送到服務總線隊列,但是當運行訂閱的消息不被在FIFO基礎處理的ServiceBusTrigger的WebJob。 對於這使消息在服務總線隊列WebJob的代碼如下: NamespaceManager namespaceManager = Names

    0熱度

    2回答

    我試圖在Java中實現與https://code.msdn.microsoft.com/Brokered-Messaging-Request-0ce8fcaf#content類似的內容,但無法從服務總線Java SDK中找到與示例中使用的QueueClient.AcceptMessageSession相匹配的功能。 那麼,如何才能讓客戶端輪詢響應隊列僅適用於與預期sessionId匹配的消息?我是

    1熱度

    2回答

    我正在使用ARM模板部署到Azure。但是,Azure服務總線部署部分證明是困難的。 誰能告訴我如何配置相同的設置中的經典門戶網站,如: 重複檢測的歷史時間 鎖定時間 最大列隊規模 最大傳遞計數 缺省消息生存時間 或者是有一種方法可以在Powershell中完成,然後從ARM腳本調用它?

    6熱度

    2回答

    我創建了一個Azure Function,每次將新消息添加到Azure ServiceBus隊列時都會觸發該觸發器。 有了這個代碼,它工作正常: #r "Newtonsoft.Json" #load "..\shared\person.csx" using Newtonsoft.Json; using Newtonsoft.Json.Serialization; public stat

    0熱度

    1回答

    我正在尋找一種管理來自多個發佈者的消息流的方法。 一個人爲的例子是這樣的。 我的每個發佈商都在提交可分解爲可以按任意順序處理的較小組件的作業。每個組件需要幾秒鐘來處理。 發佈者A將作業提交給由1000個較小組件組成的隊列。使用者X訂閱隊列並開始處理隊列消息並將結果發送到結果隊列。 通過這項工作的一半,發佈者B提交了一個包含1000個組件的作業。 我希望消費者X現在在來自發布者A和發佈者B的消息之間

    1熱度

    1回答

    我接收錯誤從我的SharePoint獲取-Item操作時我嘗試從服務總線消息中使用的數據觸發我邏輯應用(內XML中省略): 無法在行''1'和列'1641'的'Get_items'輸入中處理模板語言表達式:'模板語言函數'json'參數無效。提供的值'<?xml version="1.0" encoding="utf-8"?> <Projektaufgabe id="b92d6817-694e-e

    0熱度

    1回答

    我正在嘗試部署一個Azure邏輯應用程序,其中包含使用ARM模板在服務總線上發送消息的操作。 除了部署邏輯應用程序,ARM模板還部署了服務總線名稱空間,隊列和兩個授權規則(一個用於發送,另一個用於監聽)。 我想動態設置發送服務總線消息操作的連接信息,以使用爲支持發送的AuthorizationRule生成的連接字符串。 當我創建此在門戶編輯器(指定發送連接字符串),我注意到在代碼視圖生成以下...

    1熱度

    1回答

    我試圖遍歷一個JSON數組,該數組已被編碼爲一個字符串以用於存儲隊列。然而,我收到以下錯誤消息: { 「代碼」: 「ExpressionEvaluationFailed」, 「消息」:「的 模板行動 '的for_each' 執行失敗:結果「[{\ 」富\「 :'Bar''}]' 'foreach'動作表達的評估 '@ {json(decodeBase64(triggerBody()['Conten

    0熱度

    1回答

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

    1熱度

    2回答

    我使用下一個代碼有天青webjob設置的處理: 的Program.cs: public class Program { static void Main(){ JobHostConfiguration config = new JobHostConfiguration(); config.Tracing.ConsoleLevel = TraceLevel.Verb