org.openspaces.esb.mule.eventcontainer

Class OpenSpacesMessageReceiver.GigaSpaceWorker

java.lang.Object

org.mule.transport.AbstractReceiverWorker

org.openspaces.esb.mule.eventcontainer.OpenSpacesMessageReceiver.GigaSpaceWorker

All Implemented Interfaces:

Runnable, javax.resource.spi.work.Work

Enclosing class:

OpenSpacesMessageReceiver

protected static class OpenSpacesMessageReceiver.GigaSpaceWorker
extends org.mule.transport.AbstractReceiverWorker

Field Summary

Fields inherited from class org.mule.transport.AbstractReceiverWorker

endpoint, messages, out, receiver

Constructor Summary

Constructors

Constructor and Description
GigaSpaceWorker(Object message, OpenSpacesMessageReceiver receiver, GigaSpace gigaSpace)

Method Summary

Modifier and Type	Method and Description
protected void	bindTransaction(org.mule.api.transaction.Transaction tx)
protected void	handleResults(List messages)

Methods inherited from class org.mule.transport.AbstractReceiverWorker

doRun, handleEventResults, postProcessMessage, preProcessMessage, preRouteMuleMessage, processMessages, release, run

Methods inherited from class java.lang.Object

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

Constructor Detail

GigaSpaceWorker

public GigaSpaceWorker(Object message,
                       OpenSpacesMessageReceiver receiver,
                       GigaSpace gigaSpace)

Method Detail

bindTransaction

protected void bindTransaction(org.mule.api.transaction.Transaction tx)
                        throws org.mule.api.transaction.TransactionException

Specified by:

bindTransaction in class org.mule.transport.AbstractReceiverWorker

Throws:

org.mule.api.transaction.TransactionException

handleResults

protected void handleResults(List messages)
                      throws Exception

Overrides:

handleResults in class org.mule.transport.AbstractReceiverWorker

Throws:

Exception