public class DockerEventsConsumer
extends org.apache.camel.impl.DefaultConsumer
implements com.github.dockerjava.api.command.EventCallback
Constructor and Description |
---|
DockerEventsConsumer(DockerEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
DockerEndpoint |
getEndpoint() |
boolean |
isReceiving() |
void |
onCompletion(int numEvents) |
void |
onEvent(com.github.dockerjava.api.model.Event event) |
void |
onException(Throwable throwable) |
createUoW, doneUoW, getAsyncProcessor, 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 DockerEventsConsumer(DockerEndpoint endpoint, org.apache.camel.Processor processor) throws Exception
Exception
public DockerEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
public void onEvent(com.github.dockerjava.api.model.Event event)
onEvent
in interface com.github.dockerjava.api.command.EventCallback
public void onException(Throwable throwable)
onException
in interface com.github.dockerjava.api.command.EventCallback
public void onCompletion(int numEvents)
onCompletion
in interface com.github.dockerjava.api.command.EventCallback
public boolean isReceiving()
isReceiving
in interface com.github.dockerjava.api.command.EventCallback
Apache Camel