org.apache.camel.component.stream
Class StreamEndpoint

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by 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


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
StreamEndpoint(String endpointUri)
          Deprecated. 
StreamEndpoint(String endpointUri, org.apache.camel.Component component)
           
 
Method Summary
 org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
           
protected  org.apache.camel.Exchange createExchange(Object body, long index, boolean last)
           
 org.apache.camel.Producer createProducer()
           
protected  void doStart()
           
 int getAutoCloseCount()
           
 Charset getCharset()
           
 long getDelay()
           
 String getEncoding()
           
 String getFileName()
           
 int getGroupLines()
           
 GroupStrategy getGroupStrategy()
           
 long getInitialPromptDelay()
           
 long getPromptDelay()
           
 String getPromptMessage()
           
 long getScanStreamDelay()
           
 String getUrl()
           
 boolean isCloseOnDone()
           
 boolean isRetry()
           
 boolean isScanStream()
           
 boolean isSingleton()
           
 void setAutoCloseCount(int autoCloseCount)
           
 void setCloseOnDone(boolean closeOnDone)
           
 void setDelay(long delay)
           
 void setEncoding(String encoding)
           
 void setFileName(String fileName)
           
 void setGroupLines(int groupLines)
           
 void setGroupStrategy(GroupStrategy strategy)
           
 void setInitialPromptDelay(long initialPromptDelay)
           
 void setPromptDelay(long promptDelay)
           
 void setPromptMessage(String promptMessage)
           
 void setRetry(boolean retry)
           
 void setScanStream(boolean scanStream)
           
 void setScanStreamDelay(long scanStreamDelay)
           
 void setUrl(String url)
           
 
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 class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

StreamEndpoint

public StreamEndpoint(String endpointUri,
                      org.apache.camel.Component component)
               throws Exception
Throws:
Exception

StreamEndpoint

@Deprecated
public StreamEndpoint(String endpointUri)
Deprecated. 

Method Detail

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