org.mule.model.seda
Class SedaService
java.lang.Object
org.mule.service.AbstractService
org.mule.model.seda.SedaService
- All Implemented Interfaces:
- Serializable, AnnotatedObject, FlowConstruct, Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, NameableObject, NamedObject, MessageProcessor, Service
public class SedaService
- extends AbstractService
A Seda service runs inside a Seda Model and is responsible for managing a Seda
Queue and thread pool for a Mule sevice service. In Seda terms this is equivilent
to a stage.
- See Also:
- Serialized Form
Fields inherited from class org.mule.service.AbstractService |
asyncReplyMessageSource, component, exceptionListener, INITIAL_STATE_PAUSED, INITIAL_STATE_STARTED, INITIAL_STATE_STOPPED, initialState, lifecycleManager, logger, messageInfoMapping, messageProcessorChain, messageSource, model, muleContext, name, outboundRouter, stats |
Methods inherited from class org.mule.service.AbstractService |
buildServiceMessageProcessorChain, createAsyncReplyProcessor, dispatchEvent, dispose, disposeIfDisposable, doDispose, doForceStop, doStart, doStop, forceStop, getAnnotation, getAnnotations, getAsyncReplyMessageSource, getAsyncReplyTimeout, getComponent, getExceptionListener, getInitialState, getLifecycleManager, getLifecycleState, getMessageInfoMapping, getMessageProcessorChain, getMessageSource, getModel, getMuleContext, getName, getOutboundMessageProcessor, getStatistics, initialise, initialiseIfInitialisable, injectFlowConstructMuleContext, isPaused, isStarted, isStopped, isStopping, pause, pauseIfPausable, process, resume, resumeIfResumable, sendEvent, setAnnotations, setAsyncReplyMessageSource, setComponent, setExceptionListener, setInitialState, setMessageInfoMapping, setMessageProcessor, setMessageSource, setModel, setName, setOutboundMessageProcessor, start, startIfStartable, stop, stopIfStoppable, toString |
queueTimeout
protected Integer queueTimeout
- The time out used for taking from the Seda Queue.
threadingProfile
protected ThreadingProfile threadingProfile
- The threading profile to use for this service. If this is not set a default
will be provided by the server
queueProfile
protected QueueProfile queueProfile
- The queue profile to use for this service. If this is not set a default will
be provided by the server
sedaStage
protected SedaStageInterceptingMessageProcessor sedaStage
SedaService
public SedaService(MuleContext muleContext)
getServiceStartedAssertingMessageProcessor
protected MessageProcessor getServiceStartedAssertingMessageProcessor()
- Overrides:
getServiceStartedAssertingMessageProcessor
in class AbstractService
addMessageProcessors
protected void addMessageProcessors(MessageProcessorChainBuilder builder)
- Specified by:
addMessageProcessors
in class AbstractService
doInitialise
protected void doInitialise()
throws InitialisationException
- Initialise the service. The service will first create a Mule component from
the Service and then initialise a pool based on the attributes in the Service.
- Overrides:
doInitialise
in class AbstractService
- Throws:
InitialisationException
- if the service fails to
initialise
createStatistics
protected ServiceStatistics createStatistics()
- Overrides:
createStatistics
in class AbstractService
getQueueProfile
public QueueProfile getQueueProfile()
setQueueProfile
public void setQueueProfile(QueueProfile queueProfile)
getQueueTimeout
public Integer getQueueTimeout()
setQueueTimeout
public void setQueueTimeout(Integer queueTimeout)
getThreadingProfile
public ThreadingProfile getThreadingProfile()
setThreadingProfile
public void setThreadingProfile(ThreadingProfile threadingProfile)
doPause
protected void doPause()
throws MuleException
- Description copied from class:
AbstractService
- Custom components can execute code necessary to put the service in a paused state here. If a developer
overloads this method the doResume() method MUST also be overloaded to avoid inconsistent state in the
service
- Overrides:
doPause
in class AbstractService
- Throws:
MuleException
doResume
protected void doResume()
throws MuleException
- Description copied from class:
AbstractService
- Custom components can execute code necessary to resume a service once it has
been paused If a developer overloads this method the doPause() method MUST
also be overloaded to avoid inconsistent state in the service
- Overrides:
doResume
in class AbstractService
- Throws:
MuleException
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.