msgconsumer.java

测试servicemix的jbi标准组件

package javax.jbi;
import org.apache.servicemix.components.util;
import java.util.Timer;
public class MsgConsumer extends Outbinding{
	private Timer timer;
	
	protected void init() throws JBIException{
		timer = new Timer();
	}
	
	public void start() throws JBIException{
		timer.schedule(new TimerTask(){
			private long i=0;
			public void run(){
				sendInOut();
			}
		}
		,1000,1000);
	}
	public void stop() throws JBIException{
		timer.cancel();
	}
	
	public void sendInOut(){
		try{
			String msg = "<message type=\"InOut\">hello word</message>";
			InOut exchange = getExchangeFactory().createInOutExchange();
			NormalizedMessage message = exchange.createMessage();
			message.setContent(new StringSource(msg));
			exchange.setInMessage(message);
			//同步发送
			getDeliveryChannel().sendSync(exchange);
			if(exchange.getStatus()==ExchangeStatus.ACTIVE){
				NormalizedMessage out = exchange.getOutMessage();
				system.out.println(getContext().getComponentName()+content);
			}
			done(exchange);
			
		}catch(MessagingException e){
			e.printStackTrace();
		}catch(TransformerException e){
			e.printStackTrace();
		}
	}
	

}