jmstemplate

18熱度

4回答

有兩個程序：訂閱者和發佈者... 訂戶能夠將消息放到主題上，並且消息已成功發送。當我檢查我的瀏覽器上的activemq服務器時，它顯示1 msg入隊。但是，當我運行了消費者的代碼，它不接收消息這裏是生產者代碼： import javax.jms.*; import org.apache.activemq.ActiveMQConnection; import org.apache.acti

1熱度

1回答

使用特殊字符時JMS編碼的消息選擇器不匹配

我有2個應用程序（客戶端和服務器）使用請求 - 應答模式。客戶端向服務器發送一個請求消息ID設置爲這樣的：ID=Hostname-52991-1357677886768-3:1:2:1:1。現在，客戶端必須偵聽相關ID設置爲相同值的消息。由於該值包含特殊字符（:)我必須對該值進行編碼（使用UTF-8）。設置JMS選擇器，它是用於在代理中過濾消息的SQL 92謂詞。您可能需要特殊字符進行編碼，

1熱度

1回答

Spring JMSTemplate - 丟失的消息

我們使用Spring JMSTemplate 3.0.1RELEASE將JMS消息發送到ActiveMQ集羣。我正在使用useAsynSend = true來發送異步請求，因爲這些都是Fire和Forget。但是它們仍然是持久的，我可以確認它們首先保持在AMQ Kaha-DB上，然後轉發到Message Listeners。沒有CorelationID或JMSReplyTo，因爲我沒有收聽任何回

1熱度

1回答

不能在春註解配置的JNDI查找找到了JBoss的ConnectionFactory

儘管似乎是JBoss的一個成功的結合（AS 7.1.1.Final）連接工廠： [org.jboss.as.messaging] (MSC service thread 1-9) JBAS011601: Bound messaging object to jndi name java:/ConnectionFactory 在查找ConnectionFactory的始終爲空。任何人都可以看到問題

1熱度

1回答

JMS/spring/AMQ異步處理消息時出現問題或混淆

我們有一種情況，我們設置了一個組件來遠程使用spring批處理運行批處理作業。我們發送帶有作業xml路徑，名稱，參數等的JMS消息，然後等待調用批處理客戶端獲取服務器的響應。服務器讀取隊列，並調用適當的方法來運行作業並返回結果，而我們的通信框架不會通過： this.jmsTemplate.send(queueName, messageCreator); this.LOGGER.debu

0熱度

1回答

如何使用單個作業/ JMSwriter在彈簧批處理中發佈多個隊列

我是Spring Batch的新手，最近開始使用它。我有一個要求，我需要在每個數據庫記錄中使用單個作業發佈/寫入消息。因爲我必須使用閱讀器讀取來自DB的消息並使用處理器來決定我必須發佈哪個隊列。所以我的問題是我可以使用單個JMSwriter發佈消息在不同的隊列，因爲我必須使用單個作業和數據庫讀取器。由於提前

4熱度

3回答

ACTIVEMQ - 訂閱者在發佈者之後啓動時如何接收主題消息？

在我的程序中，我有兩個模塊： - 通過主題進行通信的發佈者和訂閱者。據我所知，爲了接收訂閱者的消息，應該在發佈者之前啓動它。但可能會出現用戶由於某種原因停機並需要重新啓動的情況。有什麼辦法，如果我在發佈者之後啓動訂閱者，那麼它也應該能夠接收消息？

1熱度

2回答

TransactionSynchronization.afterCompletion中的IncompatibleClassChangeError

每當我發送帶有JmsTemplate的消息時，都會拋出異常。（我用Spring 3.0.5.RELEASE）。我無法找到不兼容的類！春瓶在我的類路徑：錯誤日誌： springframework.transaction.support.TransactionSynchronizationUtils.invokeAfterCompletion(136) | TransactionSynchron

1熱度

2回答

ActiveMQ：消息監聽器不處理隊列中的所有條目

我們有一個要求，我將在n個服務器上部署一個應用程序，比如S1，S2，... Sn。有一個activeMQ隊列定義在其中一臺服務器，比如說S1.I已經配置了我的服務器來生成消息並將它們放置在S1中配置的同一隊列中。儘管所有服務器都配置爲使用相同的隊列來存儲生成的消息，但我的要求是隻有n個服務器中的一個處理來自隊列的所有消息，再次說明S1。因此，當所有服務器從S1， S2，... Sn可以生成並將它們

0熱度

1回答

未收到JMS消息

我在使用HornetQ時遇到了一個奇怪的情況。我的應用程序體系結構 - JMS提供者：HornetQ的（獨立服務器，不用於其他任何東西，我創建了這個服務器上的2個隊列，稱Q1和Q2）。 Producer：部署在單獨機器上的Web應用程序。此應用程序創建「ObjectMessage」的實例，將「Job」類實例作爲參數傳遞給「ObjectMessage.setObject（）」方法，並將消息添加到Q