org.apache.camel.component.flatpack
Class DelimitedEndpoint

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.impl.ScheduledPollEndpoint
              org.apache.camel.impl.DefaultPollingEndpoint
                  org.apache.camel.component.flatpack.FixedLengthEndpoint
                      org.apache.camel.component.flatpack.DelimitedEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class DelimitedEndpoint
extends FixedLengthEndpoint

Version:

Field Summary

Fields inherited from class org.apache.camel.component.flatpack.FixedLengthEndpoint

definition

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

DelimitedEndpoint()

DelimitedEndpoint(String endpointUri, org.apache.camel.Component component, String resourceUri)

Method Summary

net.sf.flatpack.Parser	createParser(org.apache.camel.Exchange exchange)
char	getDelimiter()
char	getTextQualifier()
boolean	isIgnoreFirstRecord()
void	setDelimiter(char delimiter)
void	setIgnoreFirstRecord(boolean ignoreFirstRecord)
void	setTextQualifier(char textQualifier)

Methods inherited from class org.apache.camel.component.flatpack.FixedLengthEndpoint

createConsumer, createParser, createProducer, getDefinition, getLoadBalancer, getParserFactory, isAllowShortLines, isIgnoreExtraColumns, isSingleton, isSplitRows, processDataSet, setAllowShortLines, setIgnoreExtraColumns, setLoadBalancer, setParserFactory, setSplitRows

Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint

configureProperties

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

DelimitedEndpoint

public DelimitedEndpoint()

DelimitedEndpoint

public DelimitedEndpoint(String endpointUri,
                         org.apache.camel.Component component,
                         String resourceUri)

Method Detail

createParser

public net.sf.flatpack.Parser createParser(org.apache.camel.Exchange exchange)
                                    throws org.apache.camel.InvalidPayloadException,
                                           IOException

Overrides:

createParser in class FixedLengthEndpoint

Throws:

org.apache.camel.InvalidPayloadException

IOException

getDelimiter

public char getDelimiter()

setDelimiter

public void setDelimiter(char delimiter)

isIgnoreFirstRecord

public boolean isIgnoreFirstRecord()

setIgnoreFirstRecord

public void setIgnoreFirstRecord(boolean ignoreFirstRecord)

getTextQualifier

public char getTextQualifier()

setTextQualifier

public void setTextQualifier(char textQualifier)