使用 solace 和 jms 时发生冲突的 bean

问题描述

我正在尝试从 Solace 的多个 JMS 队列中读取数据，然后将消息发布到 weblogic JMS 队列。问题是，由于源和目标都是 JMS，我得到了一个冲突的 bean。在将 weblogic JMS 的配置类引入代码之前，用于从 Solace Queues 读取消息的类工作良好。一旦我引入 Appconfig 类，SolcaeListner.class 就开始侦听 weblogic 上的队列（不存在），因此出错。

SolaceListner 类：

@EnableJms @Component 公共类 SolaceListner 实现 JmsListenerConfigurer {

@Value("${sol.InQueues}")
private String[] inQueues;

@Qualifier("default")
@Override
public void configureJmsListeners(JmsListenerEndpointRegistrar registrar) {
int i = 0;
for (String inQueue : inQueues) {
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setId("myJmsEndpoint-" + i++);
endpoint.setDestination(inQueue);
endpoint.setMessageListener(new MessageListener() {

            @Override
            public void onMessage(Message message) {
                System.out.println("Message received is : " + message);

                TextMessage tm = (TextMessage) message;
                try {
                    System.out.println("TextMessage= " + tm.getText());
                    JMSSender js = new JMSSender();
                    js.sender(tm.getText());
                } catch (JMSException e) {
                    // Todo Auto-generated catch block
                    e.printstacktrace();
                }

            }

        });

        registrar.registerEndpoint(endpoint);
        System.out.println("Registered the endpoint for queue: " + inQueue);

    }

}

}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）