org.openspaces.esb.mule.seda
Class OpenSpacesSedaService

java.lang.Object
  org.mule.service.AbstractService
      org.mule.model.seda.SedaService
          org.openspaces.esb.mule.seda.SpaceAwareSedaService
              org.openspaces.esb.mule.seda.OpenSpacesSedaService

All Implemented Interfaces:

Serializable, Runnable, EventListener, Work, WorkListener, org.mule.api.context.MuleContextAware, org.mule.api.lifecycle.Disposable, org.mule.api.lifecycle.Initialisable, org.mule.api.lifecycle.Lifecycle, org.mule.api.lifecycle.Startable, org.mule.api.lifecycle.Stoppable, org.mule.api.NamedObject, org.mule.api.service.Service, ApplicationListener

public class OpenSpacesSedaService
extends SpaceAwareSedaService
implements Work, WorkListener

A SEDA component using the Space as the queue. The queue is a virtualized queue represented by the InternalEventEntry with the service name set (and not the actual event). This allows for simple failover support inherited by the Space.

Author:

kimchy

See Also:

Serialized Form

Field Summary

Fields inherited from class org.openspaces.esb.mule.seda.SpaceAwareSedaService

gigaSpace, sedaModel

Fields inherited from class org.mule.model.seda.SedaService

queue, queueProfile, queueTimeout, threadingProfile, workManager

Fields inherited from class org.mule.service.AbstractService

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

Fields inherited from interface org.mule.api.lifecycle.Initialisable

PHASE_NAME

Fields inherited from interface org.mule.api.lifecycle.Startable

PHASE_NAME

Fields inherited from interface org.mule.api.lifecycle.Stoppable

PHASE_NAME

Fields inherited from interface org.mule.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

OpenSpacesSedaService()
For Spring only

Method Summary

protected org.mule.api.MuleEvent	dequeue()
void	doInitialise()
protected void	enqueue(org.mule.api.MuleEvent event)
int	getQueueSize()

Methods inherited from class org.openspaces.esb.mule.seda.SpaceAwareSedaService

doDispose, onApplicationEvent, start, stop

Methods inherited from class org.mule.model.seda.SedaService

createStatistics, dispatchToOutboundRouter, doDispatch, doForceStop, doSend, doStart, doStop, getInstance, getQueueProfile, getQueueTimeout, getThreadingProfile, getWorkManager, handleWorkException, release, run, setQueueProfile, setQueueTimeout, setThreadingProfile, setWorkManager, workAccepted, workCompleted, workRejected, workStarted

Methods inherited from class org.mule.service.AbstractService

connectListeners, disconnectListeners, dispatchEvent, dispose, doPause, doResume, fireComponentNotification, forceStop, getComponent, getExceptionListener, getInboundRouter, getIncomingEndpoints, getInitialState, getModel, 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, startListeners, stopListeners, toString, unregisterListeners, waitIfPaused

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface javax.resource.spi.work.Work

release

Methods inherited from interface java.lang.Runnable

run

Methods inherited from interface javax.resource.spi.work.WorkListener

workAccepted, workCompleted, workRejected, workStarted

Constructor Detail

OpenSpacesSedaService

public OpenSpacesSedaService()

For Spring only

Method Detail

doInitialise

public void doInitialise()
                  throws org.mule.api.lifecycle.InitialisationException

Overrides:

doInitialise in class SpaceAwareSedaService

Throws:

org.mule.api.lifecycle.InitialisationException

enqueue

protected void enqueue(org.mule.api.MuleEvent event)
                throws Exception

Overrides:

enqueue in class org.mule.model.seda.SedaService

Throws:

Exception

dequeue

protected org.mule.api.MuleEvent dequeue()
                                  throws Exception

Overrides:

dequeue in class org.mule.model.seda.SedaService

Throws:

Exception

getQueueSize

public int getQueueSize()

Overrides:

getQueueSize in class org.mule.model.seda.SedaService