Class HippoEventConsumer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultConsumer
-
- org.onehippo.forge.camel.component.hippo.HippoEventConsumer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Consumer
,org.apache.camel.EndpointAware
,org.apache.camel.health.HealthCheckAware
,org.apache.camel.RouteAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.RouteIdAware
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class HippoEventConsumer extends org.apache.camel.support.DefaultConsumer implements org.apache.camel.SuspendableService
HippoEventConsumer.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
HippoEventConsumer.HippoLocalEventListener
class
HippoEventConsumer.HippoPersistedEventListener
-
Field Summary
Fields Modifier and Type Field Description static String
PERSISTED_LISTENER_CHANNEL_NAME
static String
PERSISTED_LISTENER_FLAG
static String
PERSISTED_LISTENER_ONLY_NEW_EVENTS_FLAG
-
Constructor Summary
Constructors Constructor Description HippoEventConsumer(HippoEventEndpoint endpoint, org.apache.camel.Processor processor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.camel.Exchange
createExchange(org.onehippo.cms7.event.HippoEvent<?> event, net.sf.json.JSONObject messageBody)
protected net.sf.json.JSONObject
createMessageBody(org.onehippo.cms7.event.HippoEvent<?> event)
protected void
doStart()
protected void
doStop()
protected void
handleHippoEvent(org.onehippo.cms7.event.HippoEvent<?> event)
protected boolean
isConsumable(org.onehippo.cms7.event.HippoEvent<?> event, net.sf.json.JSONObject messageBody)
-
Methods inherited from class org.apache.camel.support.DefaultConsumer
createExchange, createUoW, defaultConsumerCallback, doBuild, doInit, doneUoW, doShutdown, getAsyncProcessor, getEndpoint, getExceptionHandler, getHealthCheck, getProcessor, getRoute, getRouteId, handleException, handleException, releaseExchange, setExceptionHandler, setHealthCheck, setRoute, setRouteId, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doFail, doLifecycleChange, doResume, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
PERSISTED_LISTENER_FLAG
public static final String PERSISTED_LISTENER_FLAG
- See Also:
- Constant Field Values
-
PERSISTED_LISTENER_CHANNEL_NAME
public static final String PERSISTED_LISTENER_CHANNEL_NAME
- See Also:
- Constant Field Values
-
PERSISTED_LISTENER_ONLY_NEW_EVENTS_FLAG
public static final String PERSISTED_LISTENER_ONLY_NEW_EVENTS_FLAG
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
HippoEventConsumer
public HippoEventConsumer(HippoEventEndpoint endpoint, org.apache.camel.Processor processor)
-
-
Method Detail
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.DefaultConsumer
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.DefaultConsumer
- Throws:
Exception
-
createMessageBody
protected net.sf.json.JSONObject createMessageBody(org.onehippo.cms7.event.HippoEvent<?> event)
-
createExchange
protected org.apache.camel.Exchange createExchange(org.onehippo.cms7.event.HippoEvent<?> event, net.sf.json.JSONObject messageBody)
-
isConsumable
protected boolean isConsumable(org.onehippo.cms7.event.HippoEvent<?> event, net.sf.json.JSONObject messageBody)
-
handleHippoEvent
protected void handleHippoEvent(org.onehippo.cms7.event.HippoEvent<?> event)
-
-