JacksonDataFormatSplitExpression.java

public class JacksonDataFormatSplitExpression extends ExpressionAdapter
{

    private final JacksonDataFormat format;
    private final FormatSchema schema;

    public JacksonDataFormatSplitExpression(JacksonDataFormat format, FormatSchema schema)
    {
        this.format = format;
        this.schema = schema;
    }

    @Override
    public Object evaluate(Exchange exchange)
    {
        try
        {
            return format.getObjectMapper()
                .reader(schema)
                .withType(format.getUnmarshalType())
                .withView(format.getJsonView())
                .readValues(exchange.getIn().getBody(Reader.class));
        }
        catch (IOException e)
        {
            throw new RuntimeCamelException("Unable to read data with Jackson object mapper", e);
        }
    }

}