org.openspaces.esb.mule.seda
Class SpaceAwareSedaService

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

All Implemented Interfaces:

Serializable, Runnable, EventListener, javax.resource.spi.work.Work, javax.resource.spi.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

Direct Known Subclasses:

OpenSpacesSedaService

public class SpaceAwareSedaService
extends org.mule.model.seda.SedaService
implements ApplicationListener

An extension to Mule SEDA component that will only start when working with a PRIMARY space and won't start when working with BACKUP space.

Author:

kimchy

See Also:

Serialized Form

Field Summary

protected GigaSpace	gigaSpace
protected OpenSpacesSedaModel	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, 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

SpaceAwareSedaService()

Method Summary

protected void	doDispose()
void	doInitialise()
void	onApplicationEvent(ApplicationEvent applicationEvent)
void	start()
void	stop()

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

createStatistics, dequeue, dispatchToOutboundRouter, doDispatch, doForceStop, doSend, doStart, doStop, enqueue, getInstance, getQueueProfile, getQueueSize, 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, fireServiceNotification, forceStop, getComponent, getExceptionListener, getInboundRouter, getIncomingEndpoints, getInitialState, getModel, getMuleContext, getName, getOutboundRouter, getReplyToHandler, getResponseRouter, getStatistics, handleException, initialise, invokeComponent, 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

Field Detail

sedaModel

protected OpenSpacesSedaModel sedaModel

gigaSpace

protected GigaSpace gigaSpace

Constructor Detail

SpaceAwareSedaService

public SpaceAwareSedaService()

Method Detail

doInitialise

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

Overrides:

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

Throws:

org.mule.api.lifecycle.InitialisationException

start

public void start()
           throws org.mule.api.MuleException

Specified by:

start in interface org.mule.api.lifecycle.Startable

Overrides:

start in class org.mule.service.AbstractService

Throws:

org.mule.api.MuleException

stop

public void stop()
          throws org.mule.api.MuleException

Specified by:

stop in interface org.mule.api.lifecycle.Stoppable

Overrides:

stop in class org.mule.service.AbstractService

Throws:

org.mule.api.MuleException

doDispose

protected void doDispose()

Overrides:

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

onApplicationEvent

public void onApplicationEvent(ApplicationEvent applicationEvent)

Specified by:

onApplicationEvent in interface ApplicationListener