public class StreamConsumer extends org.apache.camel.impl.DefaultConsumer implements Runnable
Constructor and Description |
---|
StreamConsumer(StreamEndpoint endpoint,
org.apache.camel.Processor processor,
String uri) |
Modifier and Type | Method and Description |
---|---|
protected void |
doPromptMessage()
Strategy method for prompting the prompt message
|
protected void |
doStart() |
void |
doStop() |
protected long |
processLine(String line,
boolean last,
long index)
Strategy method for processing the line
|
void |
run() |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public StreamConsumer(StreamEndpoint endpoint, org.apache.camel.Processor processor, String uri) throws Exception
Exception
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
public void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
protected long processLine(String line, boolean last, long index) throws Exception
Exception
protected void doPromptMessage()
Apache Camel