public class PgEventConsumer
extends org.apache.camel.impl.DefaultConsumer
implements com.impossibl.postgres.api.jdbc.PGNotificationListener
Constructor and Description |
---|
PgEventConsumer(PgEventEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
void |
notification(int processId,
String channel,
String payload) |
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 PgEventConsumer(PgEventEndpoint endpoint, org.apache.camel.Processor processor)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
public void notification(int processId, String channel, String payload)
notification
in interface com.impossibl.postgres.system.NotificationListener
Apache Camel