msgprovider.java

测试servicemix的jbi标准组件

public class MsgProvider extends OutBinding{
	protected void process(MessageExchange exchange,NormalizedMessage message)throws MessagingException{
		try{
			String content = new sourceTransformer().toString(message.getContent());
			System.out.println(getContext().getComponentName()+content);
			if(exchange instanceof InOut){
				NormalizeedMessage out = exchange.createMessage();
				String msg = "<message type=\"InOut\">recived</message>";
				out.setContent(new StringSource(msg));
				((InOut)exchange).setOutMessage(out);
				send(exchange);
					
			}else{
				throw new MessagingException("Unknown messageChange type");
				}
		}catch(TransformerException e){
			e.printStackTrace();
		}
	}

}