camel入门 xmpp tcp 配置 之XmppSender

 

我这么厚道的把源代码贴回来，兄弟们是不是应该给点支持啊！

package testxmpp;

import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
import org.apache.camel.ExchangePattern;
import org.apache.camel.Message;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.log4j.Logger;

public class XmppSender {   
    private static String getdepart = "<iq id='hg9kg-39' from='ball@192.168.1.20/Camel' type='get'>"
        +"<x xmlns='jabber:iq:getdepart' departed='0' updatetime='321321'/>"
        +    "</iq>" ;
        public static void main(String [] s){
           
        try{
        CamelContext context = new DefaultCamelContext();

        context.start();
        //?textline=true&sync=false"
        Endpoint endpoint = context.getEndpoint("mina:tcp://192.168.1.20:5201");

        Exchange exchange = (Exchange)endpoint.createExchange(ExchangePattern.InOut);

        Message in = exchange.getIn();
        in.setHeader("foo", "bar") ;
        in.setBody(getdepart);
        in.setMessageId("111") ;
       
        Logger.getLogger(XmppSender.class).info("foo = "+in.getHeader("foo")) ;
        Producer producer = endpoint.createProducer();

        producer.start();

        producer.process(exchange);

        Message out = exchange.getOut();

        System.out.println(out.getBody());

        producer.stop();

        context.stop();

        }catch(Throwable ex)
        {
            ex.printStackTrace();
        }

        } 
}