GigaSpaces XAP 7.0 API

org.openspaces.esb.mule.seda
Class OpenSpacesSedaService

java.lang.Object
  extended by org.mule.service.AbstractService
      extended by org.mule.model.seda.SedaService
          extended by org.openspaces.esb.mule.seda.SpaceAwareSedaService
              extended by org.openspaces.esb.mule.seda.OpenSpacesSedaService
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

public class OpenSpacesSedaService
extends SpaceAwareSedaService
implements javax.resource.spi.work.Work, javax.resource.spi.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, 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, 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
 
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

GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.