publish-subscribe

    2熱度

    1回答

    這個問題之前詢問here和here但我沒有從那裏得到答案。 我正在開發應用程序,其中我使用pubsub和xmpp,對於android我正在使用smack庫。我想發送自定義有效載荷到節點和接收自定義有效載荷如何解析並顯示在列表中?現在我能夠發送和接收消息,但這只是文檔的一個小例子。這裏是我的榜樣, String msg = "room pubsub test"; SimplePayload pa

    0熱度

    1回答

    3年前,我曾在這裏我們使用的服務總線一個corebanking項目和它的工作非常好,現在我們正試圖使遷移從.net框架。淨標準2.0,但我們仍然沒有準確的事情可行性的看法,我只想知道當前版本的服務總線是否被.Net Standard 2.0支持。 預先感謝您。很有幫助。

    0熱度

    1回答

    我不能完全肯定這是提出正確的地方,但我對的RabbitMQ的運作問題,實現發佈/訂閱消息系統。我調查的RabbitMQ,看它是否適合我工作的公司的需要,我找不到任何回答這些問題無論是在官方文檔或在互聯網上: 是否有可能爲一消費者訂閱一組發佈者?我想這是可能的,如果我們想要訂閱的所有發佈者都將他們的消息發送給交換機,然後將它們轉發給訂閱者。執行此操作最適合的呼氣類型是什麼? 是否可以訂閱一組主題?例

    0熱度

    1回答

    當前我有AWS IoT,它向正在偵聽的客戶端發佈消息。 但是,現在我想讓AWS的東西在S3存儲桶發生變化時將消息發佈到客戶端。類似於lambda或SNS的工作方式。觸發點應該是S3 bucket中的修改。 任何建議將是真正有用的

    3熱度

    1回答

    每隔一段時間我都會用某個查詢來檢索推文。 這些推文必須傳遞給計算和處理這些推文的服務。 因此,這些服務已訂閱到我的發佈者。所以publisher.hasSubscribers()返回true。但提交或提供功能不會調用我的訂戶的onNext。 所以作爲一個「修復」,我循環通過我的訂閱者並自己調用它。但事實並非如此。 這是我的出版商的構造函數。 public TwitterStreamer(Execu

    0熱度

    1回答

    我們正在構建一個應用程序,其中物聯網設備(溫度傳感器)將數據推送到Azure IoT Hub。 而且會有一個webjob將讀取這些數據並將其推送到數據庫(與原始數據一起滾動後)。 我們還需要一個Web應用程序的功能,用戶可以訂閱任何房間/區域,並且需要將當前溫度推送到他的屏幕(每當它發生變化時)。只有當用戶在該屏幕上時,這纔是必需的。 我們正計劃爲此任務提供redis pub/sub。 012jW

    1熱度

    1回答

    我正在測試一個非常基本的Pub/Sub訂閱。我將推送端點設置爲通過App Engine中的Python Flex服務部署的應用程序。該服務位於啓用了Identity-Aware Proxy的項目中。 IAP配置爲允許通過用戶驗證的用戶訪問我們的域。 我沒有看到我的應用正在處理任何推送請求。 我關閉了IAP保護,然後看到處理請求。我把它重新打開,它們不再被處理。 我在嘗試運行Cron服務時遇到了類似

    0熱度

    1回答

    創建淘汰賽視圖模型TagsViewModel var TagsViewModel = function() { var vm = this; vm.showTags = ko.observable(false); window.shouter.subscribe(function(newValue) { vm.showTags(newValue);

    0熱度

    1回答

    我想獲取meteorJS中所有註冊用戶的數據。根據meteorJS和stackOverflow的Doc,在渲染函數中,我嘗試了一些方法(結果如提交所示)。我只收到一個空數組或訂閱新對象時,我居然有db.users 2個用戶帳戶:db.users.find的 結果() { "_id" : "uFdKrgSyeBr6msxsH", "createdAt" : ISODate("2017-10-19T1

    0熱度

    1回答

    我正在使用ActiveMq嵌入式代理。我正在使用pub/sub模型。我有多個訂閱該主題的聽衆。我正在使用默認消息偵聽器容器。 所以我開始的話題和用戶的統計數據。 用於主題的消息的數目的統計始終爲零。 DestinationStatistics statistics = destination .getDestinationStatistics(); LOG.info(