Package org.apache.camel.main
Class MainDurationEventNotifier
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.SimpleEventNotifierSupport
-
- org.apache.camel.support.EventNotifierSupport
-
- org.apache.camel.main.MainDurationEventNotifier
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.EventNotifier
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class MainDurationEventNotifier extends org.apache.camel.support.EventNotifierSupport
AEventNotifier
to trigger shutdown of the Main JVM when maximum number of messages has been processed.
-
-
Constructor Summary
Constructors Constructor Description MainDurationEventNotifier(org.apache.camel.CamelContext camelContext, int maxMessages, long maxIdleSeconds, MainShutdownStrategy shutdownStrategy, boolean stopCamelContext)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doStart()
boolean
isEnabled(org.apache.camel.spi.CamelEvent event)
void
notify(org.apache.camel.spi.CamelEvent event)
String
toString()
-
Methods inherited from class org.apache.camel.support.EventNotifierSupport
doStop, isDisabled, isIgnoreCamelContextEvents, isIgnoreExchangeCompletedEvent, isIgnoreExchangeCreatedEvent, isIgnoreExchangeEvents, isIgnoreExchangeFailedEvents, isIgnoreExchangeRedeliveryEvents, isIgnoreExchangeSendingEvents, isIgnoreExchangeSentEvents, isIgnoreRouteEvents, isIgnoreServiceEvents, isIgnoreStepEvents, setIgnoreCamelContextEvents, setIgnoreExchangeCompletedEvent, setIgnoreExchangeCreatedEvent, setIgnoreExchangeEvents, setIgnoreExchangeFailedEvents, setIgnoreExchangeRedeliveryEvents, setIgnoreExchangeSendingEvents, setIgnoreExchangeSentEvents, setIgnoreRouteEvents, setIgnoreServiceEvents, setIgnoreStepEvents
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, 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
-
-
-
-
Constructor Detail
-
MainDurationEventNotifier
public MainDurationEventNotifier(org.apache.camel.CamelContext camelContext, int maxMessages, long maxIdleSeconds, MainShutdownStrategy shutdownStrategy, boolean stopCamelContext)
-
-
Method Detail
-
notify
public void notify(org.apache.camel.spi.CamelEvent event) throws Exception
- Throws:
Exception
-
isEnabled
public boolean isEnabled(org.apache.camel.spi.CamelEvent event)
- Specified by:
isEnabled
in interfaceorg.apache.camel.spi.EventNotifier
- Overrides:
isEnabled
in classorg.apache.camel.support.EventNotifierSupport
-
-