spring-jms

    0熱度

    1回答

    我是JMS和隊列的新成員。請原諒我的知識。框架:Spring,Hibernate,帶有JMSTemplate的Spring JMS。 我有一個商業案例,調度程序爲每個X分鐘喚醒並處理記錄並將它們推入隊列。實際上,我們有2個調度程序,但是對於差異表來說,它們是相同的。因此,對於這種情況,我已經爲JMS模板實現了no xml方法(完全註釋)。我使用連接工廠和2個隊列在weblogic中設置了一個模塊。

    1熱度

    2回答

    我無法處理來自IBM MQ大消息,並得到下面的錯誤: JMSCMQ0001:WebSphere MQ的調用與compcode失敗 '1'( 'MQCC_WARNING')的原因 '2080'( 'MQRC_TRUNCATED_MSG_FAILED') 我正在使用DefaultListenerContainer,而不是直接使用IBM MQ Java API類通過MessageConsumer進行消費

    0熱度

    1回答

    我想和ActiveMQ配置JMS在春天,這裏是我的發送方碼 @Service public class SenderService implements ISenderService{ @Bean public ActiveMQConnectionFactory amqConnectionFactory() { return new ActiveMQConnec

    0熱度

    1回答

    我有一個運行在Tomcat上的Spring應用程序。 當我試圖關閉它,似乎並沒有這樣做。 這裏是的IntelliJ截圖: 這裏是我的代碼如下所示: @Service public class QueueMsgConsumer { @JmsListener(destination = Keys.QUEUE_NAME) public void processMsg(TextM

    0熱度

    1回答

    我試圖在春季集成中使用出站網關時在JMS標題中發送回覆Q詳細信息。我瞭解到JIRA#INT-97中的增強功能會將彈簧消息標題複製到JMS標頭,然後將其發送到JMS目標。 在將消息發送到出站網關之前,請按如下所示設置消息標題。 message.getHeader()。setAttribute(JmsTargetAdapter.JMS_REPLY_TO,myReplyDestination); 但我無

    0熱度

    1回答

    我們已經得到了要求我們必須推送一些消息以供離線實現,現在我們已經在線/離線混合安裝,在線我們正在推送消息到隊列中,但是對於離線我們仍然希望推送隊列,但是讀取離線消息並將其存儲在本地文件系統中,以便我們可以將其存儲在文件系統中,並讓離線系統通過將其放入隊列中來手動處理它。 我想知道如果我們在活動mq中有虛擬隊列類型的東西,我們可以放置所有脫機消息並讀取它存儲在文件系統上,然後從隊列中刪除它。 我在這

    0熱度

    2回答

    我能夠在開發中成功部署我的應用程序。我正在使用Spring JMS模板與Tibco Client進行通信,並且在weblogic中,我已經建立了一個帶有目標隊列的外部服務器,作爲Tibco隊列和連接Tibco連接工廠的連接工廠。我的JNDI初始上下文工廠:是tcp:// name:port ...我能夠發佈消息並收聽它。沒有問題。 問題: 當部署到QA(從開發戰爭取並放入QA)和在部署過程中,我們

    2熱度

    1回答

    我們正在使用Spring批處理和10服務器JBoss EAP 5.2集羣中的作業分區。由於JBoss消息中存在問題,我們需要使用分區步驟中回覆消息的主題。直到我們看到JBoss Messaging故障(在啓動作業的服務器上)並將其從集羣中刪除,所有工作都正常。它恢復,但主分區不會接收分區步驟發送的消息。我在JMX控制檯中看到主題中的消息,但也看到訂閱和消息不耐用。因此,我希望將分區步驟回覆的通信轉

    1熱度

    1回答

    上生成java消息當前在我們的一個項目中,我們有JMS服務來在輪詢器檢測到目錄內的文件時生成消息。 JMS消息是隨機生成的。我們爲此使用了入站通道適配器。我們有要求在FIFO順序上生成消息(這是基於時間戳的)。有什麼可能的辦法來實現這個..?如果是,請提出建議。 謝謝。

    2熱度

    2回答

    我有一個簡單的服務發送電子郵件。它可以使用REST和JMS API進行調用。我希望在處理之前驗證請求。 當我使用REST調用它時,我可以看到org.springframework.validation.DataBinder調用了void validate(Object target, Errors errors, Object... validationHints),然後調用了來自Hibernat