0

我在端口号 9443(esb1) 和 9446(esb2) 处使用了 WSO2 ESB 4.6 的两个实例，还在 9444 处使用了 Message Broker 2.0.1。我正在使用此 url 来执行我的任务：http ://wso2.org/图书馆/文章/2013/03/configuring-wso2-esb-wso2-message-broker。我已经使用上面的链接完成了队列到队列发送接收示例。一切正常。但问题是当我向 esb1 发布任何消息时，它会反映到 esb2，因为 esb2 作为我的订阅者工作。我希望消息存储应该存储从 esb1 传递的消息，并根据某些事件向 esb2 提供 esb1 发送的消息。提前致谢。当我激活我的按摩处理器时，我不断收到此错误：

[2013-04-08 17:58:56,658] ERROR - JobRunShell Job synapse.message.processor.quartz.Processor2-forward job threw an unhan
dled Exception:
java.lang.NullPointerException
        at org.wso2.carbon.message.store.persistence.jms.util.JMSUtil.createConnection(JMSUtil.java:46)
        at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.createConnection(JMSMessageStore.java:577)
        at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.getReadConnection(JMSMessageStore.java:517)
        at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.peek(JMSMessageStore.java:239)
        at org.apache.synapse.message.processors.forward.ForwardingJob.execute(ForwardingJob.java:88)
        at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
        at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:557)
[2013-04-08 17:58:56,669] ERROR - ErrorLogger Job (synapse.message.processor.quartz.Processor2-forward job threw an exce
ption.
org.quartz.SchedulerException: Job threw an unhandled exception. [See nested exception: java.lang.NullPointerException]
        at org.quartz.core.JobRunShell.run(JobRunShell.java:224)
        at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:557)
Caused by: java.lang.NullPointerException
        at org.wso2.carbon.message.store.persistence.jms.util.JMSUtil.createConnection(JMSUtil.java:46)
        at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.createConnection(JMSMessageStore.java:577)
        at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.getReadConnection(JMSMessageStore.java:517)
        at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.peek(JMSMessageStore.java:239)
        at org.apache.synapse.message.processors.forward.ForwardingJob.execute(ForwardingJob.java:88)
        at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
        ... 1 more
4

1 回答 1

0

看起来您的 jndi.properties 配置中存在一些问题。确保连接工厂配置有效，这似乎导致了报告的问题。在消息存储实现中，“连接工厂”参数的值默认为“QueueConnectionFactory”。如果您尝试使用不同名称指定另一个连接工厂，从配置中删除默认连接工厂 (QueueConnectionFactory)，请确保在消息存储配置的适当元素中指定正确的连接工厂名称。

希望这可以帮助！

于 2013-05-20T19:33:22.230 回答