org.apache.camel.component.stream
Class StreamEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.component.stream.StreamEndpoint
- 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 StreamEndpoint
- extends org.apache.camel.impl.DefaultEndpoint
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
StreamEndpoint
public StreamEndpoint(String endpointUri,
org.apache.camel.Component component)
throws Exception
- Throws:
Exception
StreamEndpoint
@Deprecated
public StreamEndpoint(String endpointUri)
- Deprecated.
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
isSingleton
public boolean isSingleton()
createExchange
protected org.apache.camel.Exchange createExchange(Object body,
long index,
boolean last)
getFileName
public String getFileName()
setFileName
public void setFileName(String fileName)
getUrl
public String getUrl()
setUrl
public void setUrl(String url)
getDelay
public long getDelay()
setDelay
public void setDelay(long delay)
getEncoding
public String getEncoding()
setEncoding
public void setEncoding(String encoding)
getPromptMessage
public String getPromptMessage()
setPromptMessage
public void setPromptMessage(String promptMessage)
getPromptDelay
public long getPromptDelay()
setPromptDelay
public void setPromptDelay(long promptDelay)
getInitialPromptDelay
public long getInitialPromptDelay()
setInitialPromptDelay
public void setInitialPromptDelay(long initialPromptDelay)
isScanStream
public boolean isScanStream()
setScanStream
public void setScanStream(boolean scanStream)
getGroupStrategy
public GroupStrategy getGroupStrategy()
setGroupStrategy
public void setGroupStrategy(GroupStrategy strategy)
isRetry
public boolean isRetry()
setRetry
public void setRetry(boolean retry)
isCloseOnDone
public boolean isCloseOnDone()
setCloseOnDone
public void setCloseOnDone(boolean closeOnDone)
getScanStreamDelay
public long getScanStreamDelay()
setScanStreamDelay
public void setScanStreamDelay(long scanStreamDelay)
getGroupLines
public int getGroupLines()
setGroupLines
public void setGroupLines(int groupLines)
getAutoCloseCount
public int getAutoCloseCount()
setAutoCloseCount
public void setAutoCloseCount(int autoCloseCount)
getCharset
public Charset getCharset()
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class org.apache.camel.impl.DefaultEndpoint
- Throws:
Exception
Apache Camel