我需要收到发布给JMS主题的更新,将其转换为XMPP数据包(存在数据包或PubSub数据包),然后将其路由到XMPP端点。

我将ActiveMQ用作JMS提供商,而Apache Camel作为路由引擎。下面给出的是我在骆驼中的路线(为了使事情变得简单,我从system.in而不是JMS主题阅读):

     from("stream:in?promptMessage=Enter something:").process( new Processor(){
        public void process(Exchange exchange) throws Exception {
                System.out.println("sending presence with message: " + exchange.getIn().getBody().toString());
                Presence p = new Presence(Type.available, exchange.getIn().getBody().toString(), 5, Mode.chat);
                exchange.getIn().setBody(p);
            }
            }).to("xmpp:user1@banl080161?password=pass1");

想法是,user1@banl080161应该能够发送带有System.in的状态的CUSTOMOMESCATE数据包。我正在从system.in读取,制作一个存在数据包,将此数据包设置在交换主体中,并代表User1@banl080161发送此数据包。

问题: 什么都没有发送到XMPP服务器,我使用PSI查看来自USER1@banl080161的数据包,user1@banl080161肯定是在线到线的,但是没有收到自定义的消息。

可以在Apache骆驼中做这种事情吗?

有帮助吗?

解决方案

请随时为Camel-XMPP组件创建此新功能的机票。

从此网页上有一个指向问题跟踪器的链接:http://camel.apache.org/support

许可以下: CC-BY-SA归因
不隶属于 StackOverflow
scroll top