|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultConsumer
org.apache.camel.component.stream.StreamConsumer
public class StreamConsumer
Consumer that can read from streams
Field Summary |
---|
Fields inherited from class org.apache.camel.impl.DefaultConsumer |
---|
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
StreamConsumer(StreamEndpoint endpoint,
org.apache.camel.Processor processor,
String uri)
|
Method Summary | |
---|---|
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()
|
Methods inherited from class org.apache.camel.impl.DefaultConsumer |
---|
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, 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, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Constructor Detail |
---|
public StreamConsumer(StreamEndpoint endpoint, org.apache.camel.Processor processor, String uri) throws Exception
Exception
Method Detail |
---|
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
public void run()
run
in interface Runnable
protected long processLine(String line, boolean last, long index) throws Exception
Exception
protected void doPromptMessage()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |