consumer

1熱度

1回答

如何配置WSO2 ESB 4.7 JMS消費者代理輪詢間隔？

任何人都可以告訴我是否有一個屬性允許配置JMS消費者代理輪詢隊列/主題的頻率？

-1熱度

1回答

最佳數據結構？ - 2個線程，1名製片人，1名消費者

什麼是用做以下最佳的數據結構： 2個線程： 1產生（寫入）的數據結構 1從數據結構中消耗（讀取，然後刪除）。線程安全生產者和消費者能夠訪問數據結構simultaenously 高效的大量數據

0熱度

2回答

OSGI捆綁服務消費者是否需要創建服務接口的「存根」？

我剛剛接觸OSGI技術，並且我沒有幾個基本查詢。以下是我所做的：在名爲「com.mypackage.osgi.bundle.service」的包中創建HelloWorld接口。這個接口暴露了一個方法：public String sayHello（String arg）; 在名爲「com.mypackage.osgi.bundle.service.impl」的包中創建了一個HelloWorldI

0熱度

1回答

控制HornetQ中消息的消費速度

我們想要控制消費者在HornetQ中消費消息的速度。的問題是，當我們使用ServerLocator.setConsumerMaxRate（int）方法，我們得到總是每秒1個消息，而不管我們傳遞值的。當我們不調用這個方法，是消費速度快（遠遠超過每秒1次）。我們的代碼： TransportConfiguration connectorConfig = new TransportConfigur

6熱度

4回答

Kafka高級消費者使用Java API從主題獲取所有消息（等效於 - from-beginning）

我正在使用Kafka網站的ConsumerGroupExample代碼測試Kafka高級消費者。我想檢索我在「Kafka服務器配置」中關於「測試」主題的所有現有消息。綜觀其他博客，auto.offset.reset應設置爲「最小」，以能夠得到的所有消息： private static ConsumerConfig createConsumerConfig(String a_zookeeper, S

0熱度

1回答

Java中的多個生產者單個消費者的軟件設計

我有多個生產者，每個生產者都將數據推入自己的阻塞隊列。來自每個生產者的數據是獨立處理的（因此是單獨的隊列）。我的單個消費者當前正在輪詢每個隊列，每個隊列都有一個超時。程序工作得很好，但我想優化，我不喜歡「投票」。這是最有效的方法來處理這個問題嗎？，我已經使用每個生產者的消費者編寫了相同的應用程序，但該配置文件稍差。謝謝。

0熱度

1回答

MassTransit消費者在使用Windsor集成時從未調用

我似乎無法得到適用於RabbitMQ上的Mass Transit的Castle Windsor集成。一切都很好，直到我將溫莎引入到圖片中。我引用了Castle.Windsor 3.2和MassTransit.WindsorIntegration 2.9，並將容器配置爲在我的應用程序中使用。我通過註冊MassTransit消費者： Container.Register(..., Types.From

0熱度

1回答

activeMQ上消費者的選擇問題

方案：我發送五萬消息到名爲JUST.CN的隊列。然後每消息1000個消息，我會創建一個消息propertyString「myfilter ='abc'」。現在，我使用相同的選擇器創建消費者以使用消息。但是，在30000消息之後，特別是消費速率非常慢。我無法更改activeMQ中的默認配置。核心代碼如下： IDestination destination = SessionUtil.GetDest

2熱度

3回答

谷歌消費者調查沒有出現在我的網站上

我想在我的網站上調查網站訪問者。我非常喜歡我在Google消費者調查中看到的演示機制。我無法讓調查在我的網站上呈現。 Google消費者調查控制面板中的狀態表明它已啓用，但沒有響應，因爲它不會彈出。該腳本是 <script async="" defer="" src="//survey.g.doubleclick.net/async_survey?site=[mysiteid]" </scri

0熱度

1回答

ActiveMQ，我如何創建只有一個消費者？

我正在使用Java EE和ActiveMQ。我想實現一個JMS隊列，我可以將消息發送到我的QUEUE，並且Consumer + MessageListener應該讀取此消息。的代碼爲我的消費者IST如下： private void initializeActiveMq() throws JMSException { // Create a ConnectionFactory