talend tJMSInput與WSO2 Message Broker

我正在創建一個talend作業，它將允許我從JMS隊列中獲取消息。爲此，我試圖在talend中配置一個tJMSInput組件來偵聽消息代理隊列。talend tJMSInput與WSO2 Message Broker

當我嘗試運行作業創建我得到以下錯誤：

`Démarrage du job sauvegarde a 16:23 21/07/2015`. 
[statistics] connecting to socket on port 3805 
[statistics] connected 
[main] WARN org.wso2.andes.jndi.PropertiesFileInitialContextFactory - Unable to load property file specified in Provider_URL:amqp://admin:[email protected]:carbon?brokerlist='tcp://localhost:5682' 
Due to:amqp:\admin:[email protected]:carbon?brokerlist='tcp:\localhost:5682' (La syntaxe du nom de fichier, de répertoire ou de volume est incorrecte)

異常的組件tJMSInput_1

javax.naming.NameNotFoundException: myQueueConnectionFactory 
at org.wso2.andes.jndi.ReadOnlyContext.lookup(ReadOnlyContext.java:271) 
at javax.naming.InitialContext.lookup(Unknown Source) 
at output_agent.sauvegarde_0_1.sauvegarde.tJMSInput_1Process(sauvegarde.java:882) 
at output_agent.sauvegarde_0_1.sauvegarde.tLibraryLoad_2Process(sauvegarde.java:641) 
at output_agent.sauvegarde_0_1.sauvegarde.tInitLog4J_1Process(sauvegarde.java:538) 
    at 
    output_agent.sauvegarde_0_1.sauvegarde.tPrejob_1Process(sauvegarde.java:410) 
    at 
output_agent.sauvegarde_0_1.sauvegarde.runJobInTOS(sauvegarde.java:1259) 
at output_agent.sauvegarde_0_1.sauvegarde.main(sauvegarde.java:1118) 
[statistics] disconnected 
Job sauvegarde terminé à 16:23 21/07/2015. [Code sortie=1]`

我不知道它來自URL格式或連接工廠名稱，我已經嘗試過使用ActiveMQ隊列，並且完美地工作。消息代理隊列中唯一改變的是url。

任何人都可以幫助我。

來源

2015-07-21 aboubacar diallo

我犯了一個錯誤的標題應與WSO2進行了Talend tJMSInput消息經紀人 –

你可以嘗試在調試模式下運行你的工作，看看什麼是網址g形成，哪一步是異常問題.. – garpitmzn

我發現了這個問題。

的qpid上下文工廠org.wso2.andes.jndi.PropertiesFileInitialContextFactory不使用字段相同的方式ActiveMQ的上下文工廠org.apache.activemq.jndi.ActiveMQInitialContextFactory。

雖然ActiveMQ允許您不在Talend中使用單獨的屬性文件，但Qpid不會。

了Talend配置

的tJMSInput之前，你有一個tLibraryLoad組件加載Geronimo的jms_1.1_spec-X.X.X.wso2vX.jar庫。

了Talend tJMSInput配置：

模塊列表：安第斯山脈-客戶X.XX.wso2vXX.jar
上下文提供：「org.wso2.andes.jndi.PropertiesFileInitialContextFactory」
服務器URL：「myfile.properties」
連接工廠JDNI名稱：「qpidConnectionfactory」
消息類型：隊列
消息來源：「myQueue中」

myfile.properties：

connectionfactory.qpidConnectionfactory = amqp://admin:[email protected]/carbon?brokerlist='tcp://localhost:5682' 
queue.myQueue= myQueue

參考：Qpid Wiki

來源

2015-07-23 10:13:54

talend tJMSInput與WSO2 Message Broker

回答

相關問題