public class SedaService extends AbstractService implements javax.resource.spi.work.Work, javax.resource.spi.work.WorkListener
Modifier and Type | Field and Description |
---|---|
protected Queue |
queue |
protected QueueProfile |
queueProfile
The queue profile to use for this service.
|
protected Integer |
queueTimeout
The time out used for taking from the Seda Queue.
|
protected ThreadingProfile |
threadingProfile
The threading profile to use for this service.
|
protected WorkManager |
workManager |
component, exceptionListener, inboundRouter, INITIAL_STATE_PAUSED, INITIAL_STATE_STARTED, INITIAL_STATE_STOPPED, initialised, initialState, logger, model, muleContext, name, nestedRouter, outboundRouter, paused, responseRouter, stats, stopped, stopping
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
SedaService()
For Spring only
|
Modifier and Type | Method and Description |
---|---|
protected ServiceStatistics |
createStatistics() |
protected MuleEvent |
dequeue() |
protected void |
dispatchToOutboundRouter(MuleEvent event,
MuleMessage result) |
protected void |
doDispatch(MuleEvent event) |
protected void |
doDispose() |
protected void |
doForceStop() |
protected void |
doInitialise()
Initialise the service.
|
protected MuleMessage |
doSend(MuleEvent event) |
protected void |
doStart() |
protected void |
doStop() |
protected void |
enqueue(MuleEvent event) |
Object |
getInstance() |
QueueProfile |
getQueueProfile() |
int |
getQueueSize() |
Integer |
getQueueTimeout() |
ThreadingProfile |
getThreadingProfile() |
WorkManager |
getWorkManager() |
protected void |
handleWorkException(javax.resource.spi.work.WorkEvent event,
String type) |
void |
release() |
void |
run()
While the service isn't stopped this runs a continuous loop checking for new
events in the queue.
|
void |
setQueueProfile(QueueProfile queueProfile) |
void |
setQueueTimeout(Integer queueTimeout) |
void |
setThreadingProfile(ThreadingProfile threadingProfile) |
void |
setWorkManager(WorkManager workManager) |
void |
workAccepted(javax.resource.spi.work.WorkEvent event) |
void |
workCompleted(javax.resource.spi.work.WorkEvent event) |
void |
workRejected(javax.resource.spi.work.WorkEvent event) |
void |
workStarted(javax.resource.spi.work.WorkEvent event) |
connectListeners, disconnectListeners, dispatchEvent, dispose, doPause, doResume, fireServiceNotification, forceStop, getComponent, getExceptionListener, getInboundRouter, getIncomingEndpoints, getInitialState, getModel, getMuleContext, getName, getOutboundRouter, getReplyToHandler, getResponseRouter, getStatistics, handleException, initialise, isPaused, isStarted, isStopped, isStopping, pause, processAsyncReplyRouter, processReplyTo, registerListeners, resume, sendEvent, sendToOutboundRouter, setComponent, setExceptionListener, setInboundRouter, setInitialState, setModel, setMuleContext, setName, setOutboundRouter, setResponseRouter, start, start, startListeners, stop, stopListeners, toString, unregisterListeners, waitIfPaused
protected WorkManager workManager
protected Integer queueTimeout
protected ThreadingProfile threadingProfile
protected QueueProfile queueProfile
protected Queue queue
protected void doInitialise() throws InitialisationException
doInitialise
in class AbstractService
InitialisationException
- if the service fails
to initialiseorg.mule.api.UMODescriptor
protected void doForceStop() throws MuleException
doForceStop
in class AbstractService
MuleException
protected void doStop() throws MuleException
doStop
in class AbstractService
MuleException
protected void doStart() throws MuleException
doStart
in class AbstractService
MuleException
protected void doDispose()
doDispose
in class AbstractService
protected void doDispatch(MuleEvent event) throws MuleException
doDispatch
in class AbstractService
MuleException
protected MuleMessage doSend(MuleEvent event) throws MuleException
doSend
in class AbstractService
MuleException
public int getQueueSize()
public void run()
public void release()
release
in interface javax.resource.spi.work.Work
public void workAccepted(javax.resource.spi.work.WorkEvent event)
workAccepted
in interface javax.resource.spi.work.WorkListener
public void workRejected(javax.resource.spi.work.WorkEvent event)
workRejected
in interface javax.resource.spi.work.WorkListener
public void workStarted(javax.resource.spi.work.WorkEvent event)
workStarted
in interface javax.resource.spi.work.WorkListener
public void workCompleted(javax.resource.spi.work.WorkEvent event)
workCompleted
in interface javax.resource.spi.work.WorkListener
protected void handleWorkException(javax.resource.spi.work.WorkEvent event, String type)
protected ServiceStatistics createStatistics()
createStatistics
in class AbstractService
public Object getInstance() throws MuleException
MuleException
public QueueProfile getQueueProfile()
public void setQueueProfile(QueueProfile queueProfile)
public Integer getQueueTimeout()
public void setQueueTimeout(Integer queueTimeout)
public ThreadingProfile getThreadingProfile()
public void setThreadingProfile(ThreadingProfile threadingProfile)
public WorkManager getWorkManager()
public void setWorkManager(WorkManager workManager)
protected void dispatchToOutboundRouter(MuleEvent event, MuleMessage result) throws MessagingException
dispatchToOutboundRouter
in class AbstractService
MessagingException
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.