public class BeanIOSplitter extends Object implements org.apache.camel.Expression
BeanIOSplitter
with the Camel Splitter EIP to split big payloads
using a stream mode to avoid reading the entire content into memory.Constructor and Description |
---|
BeanIOSplitter() |
BeanIOSplitter(BeanIOConfiguration configuration) |
BeanIOSplitter(String mapping,
String streamName) |
Modifier and Type | Method and Description |
---|---|
protected org.beanio.StreamFactory |
createStreamFactory(org.apache.camel.CamelContext camelContext) |
Object |
evaluate(org.apache.camel.Exchange exchange) |
<T> T |
evaluate(org.apache.camel.Exchange exchange,
Class<T> type) |
org.beanio.BeanReaderErrorHandler |
getBeanReaderErrorHandler() |
String |
getBeanReaderErrorHandlerType() |
BeanIOConfiguration |
getConfiguration() |
Charset |
getEncoding() |
org.beanio.StreamFactory |
getFactory() |
String |
getMapping() |
Properties |
getProperties() |
String |
getStreamName() |
boolean |
isIgnoreInvalidRecords() |
boolean |
isIgnoreUnexpectedRecords() |
boolean |
isIgnoreUnidentifiedRecords() |
void |
setBeanReaderErrorHandler(org.beanio.BeanReaderErrorHandler beanReaderErrorHandler) |
void |
setBeanReaderErrorHandlerType(Class<?> beanReaderErrorHandlerType) |
void |
setBeanReaderErrorHandlerType(String beanReaderErrorHandlerType) |
void |
setConfiguration(BeanIOConfiguration configuration) |
void |
setEncoding(Charset encoding) |
void |
setFactory(org.beanio.StreamFactory factory) |
void |
setIgnoreInvalidRecords(boolean ignoreInvalidRecords) |
void |
setIgnoreUnexpectedRecords(boolean ignoreUnexpectedRecords) |
void |
setIgnoreUnidentifiedRecords(boolean ignoreUnidentifiedRecords) |
void |
setMapping(String mapping) |
void |
setProperties(Properties properties) |
void |
setStreamName(String streamName) |
public BeanIOSplitter(BeanIOConfiguration configuration)
protected org.beanio.StreamFactory createStreamFactory(org.apache.camel.CamelContext camelContext) throws Exception
Exception
public Object evaluate(org.apache.camel.Exchange exchange) throws Exception
Exception
public <T> T evaluate(org.apache.camel.Exchange exchange, Class<T> type)
evaluate
in interface org.apache.camel.Expression
public BeanIOConfiguration getConfiguration()
public void setConfiguration(BeanIOConfiguration configuration)
public org.beanio.StreamFactory getFactory()
public void setFactory(org.beanio.StreamFactory factory)
public String getMapping()
public void setIgnoreUnexpectedRecords(boolean ignoreUnexpectedRecords)
public void setProperties(Properties properties)
public void setStreamName(String streamName)
public boolean isIgnoreUnidentifiedRecords()
public boolean isIgnoreInvalidRecords()
public void setIgnoreInvalidRecords(boolean ignoreInvalidRecords)
public void setEncoding(Charset encoding)
public boolean isIgnoreUnexpectedRecords()
public Properties getProperties()
public String getStreamName()
public void setMapping(String mapping)
public void setIgnoreUnidentifiedRecords(boolean ignoreUnidentifiedRecords)
public Charset getEncoding()
public org.beanio.BeanReaderErrorHandler getBeanReaderErrorHandler()
public void setBeanReaderErrorHandler(org.beanio.BeanReaderErrorHandler beanReaderErrorHandler)
public String getBeanReaderErrorHandlerType()
public void setBeanReaderErrorHandlerType(String beanReaderErrorHandlerType)
public void setBeanReaderErrorHandlerType(Class<?> beanReaderErrorHandlerType)
Apache Camel