Camel Edifact producer

XmlProducer.java

import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
import org.apache.camel.impl.DefaultProducer;
import org.milyn.Smooks;
import org.milyn.smooks.edi.unedifact.UNEdifactReaderConfigurator;

import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.stream.StreamSource;
import java.io.ByteArrayInputStream;
import java.io.StringWriter;

public class XmlProducer extends DefaultProducer {

    private final Smooks smooks = new Smooks();

    public XmlProducer(Endpoint endpoint, Type edifactType) {
        super(endpoint);
        smooks.setReaderConfig(new UNEdifactReaderConfigurator(edifactType.urn()));
    }

    @Override
    public void process(Exchange exchange) throws Exception {
        String exchangeBody = exchange.getIn().getBody(String.class);

        ByteArrayInputStream edifact = new ByteArrayInputStream(exchangeBody.getBytes());
        StringWriter xml = new StringWriter();

        // stream source must be backed by a byte stream
        smooks.filterSource(new StreamSource(edifact), new StreamResult(xml));

        exchange.getIn().setBody(xml.toString());
    }
}