org.openspaces.remoting

Class EventDrivenSpaceRemotingEntry

java.lang.Object

org.openspaces.remoting.EventDrivenSpaceRemotingEntry

All Implemented Interfaces:

SmartExternalizable, Externalizable, Serializable, Cloneable, SpaceRemotingEntry, SpaceRemotingInvocation, SpaceRemotingResult

Direct Known Subclasses:

EventDrivenSpaceRemotingFifoEntry, HashedEventDrivenSpaceRemotingEntry

public class EventDrivenSpaceRemotingEntry
extends Object
implements SpaceRemotingEntry, SmartExternalizable

Default implementation of a remoting entry that acts both as a remote invocation and a remote result.

Author:

kimchy

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EventDrivenSpaceRemotingEntry() Constructs a new Async remoting entry.

Method Summary

Modifier and Type	Method and Description
SpaceRemotingEntry	buildInvocation(String lookupName, String methodName, Object[] arguments)
SpaceRemotingEntry	buildResult(Object result)
SpaceRemotingEntry	buildResult(Throwable e)
SpaceRemotingEntry	buildResultTemplate()
Object	clone()
Object[]	getArguments() The arguments for the service method execution.
Throwable	getException() An exception that occured during the remote invocation.
Integer	getInstanceId() The cluster instance id this result was executed on.
String	getLookupName() The lookup name of the service.
Object[]	getMetaArguments() Meta arguments that can be passed as part of the invocation.
String	getMethodName() The method name of the service that will be executed.
Boolean	getOneWay()
Object	getResult() The result of the remote invocation.
Integer	getRouting() Routing field controls the partition the invocation will be directed to when working with a partitioned space.
String	getUid()
void	readExternal(ObjectInput in)
protected void	setArguments(Object[] arguments)
protected void	setException(Throwable exception)
void	setInstanceId(Integer instanceId)
void	setInvocation(Boolean invocation)
void	setLookupName(String lookupName)
void	setMetaArguments(Object[] metaArguments)
protected void	setMethodName(String methodName)
void	setOneWay(Boolean oneWay)
protected void	setResult(Object result)
void	setRouting(Integer routing)
void	setRouting(Object routing)
void	setUid(String uid)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Detail

EventDrivenSpaceRemotingEntry

public EventDrivenSpaceRemotingEntry()

Constructs a new Async remoting entry. By default a transient one witn that does not return a lease. Also, by default, this is an invocation entry.

Method Detail

getUid

public String getUid()

setUid

public void setUid(String uid)

setInvocation

public void setInvocation(Boolean invocation)

Specified by:

setInvocation in interface SpaceRemotingEntry

getLookupName

public String getLookupName()

Description copied from interface: SpaceRemotingInvocation

The lookup name of the service. Usually the actual interface class name that is proxied on the client side and implemented on the server side.

Specified by:

getLookupName in interface SpaceRemotingInvocation

setLookupName

public void setLookupName(String lookupName)

Specified by:

setLookupName in interface SpaceRemotingEntry

getMethodName

public String getMethodName()

Description copied from interface: SpaceRemotingInvocation

The method name of the service that will be executed.

Specified by:

getMethodName in interface SpaceRemotingInvocation

setMethodName

protected void setMethodName(String methodName)

getArguments

public Object[] getArguments()

Description copied from interface: SpaceRemotingInvocation

The arguments for the service method execution.

Specified by:

getArguments in interface SpaceRemotingInvocation

setArguments

protected void setArguments(Object[] arguments)

getMetaArguments

public Object[] getMetaArguments()

Description copied from interface: SpaceRemotingInvocation

Meta arguments that can be passed as part of the invocation. This arguments are not used to invoke the method, but can be used to control ceratin pluggable invocation "aspects".

Specified by:

getMetaArguments in interface SpaceRemotingInvocation

setMetaArguments

public void setMetaArguments(Object[] metaArguments)

Specified by:

setMetaArguments in interface SpaceRemotingEntry

getOneWay

public Boolean getOneWay()

Specified by:

getOneWay in interface SpaceRemotingEntry

setOneWay

public void setOneWay(Boolean oneWay)

Specified by:

setOneWay in interface SpaceRemotingEntry

getRouting

public Integer getRouting()

Description copied from interface: SpaceRemotingInvocation

Routing field controls the partition the invocation will be directed to when working with a partitioned space.

Specified by:

getRouting in interface SpaceRemotingInvocation

Specified by:

getRouting in interface SpaceRemotingResult

setRouting

public void setRouting(Integer routing)

setRouting

public void setRouting(Object routing)

Specified by:

setRouting in interface SpaceRemotingEntry

getResult

public Object getResult()

Description copied from interface: SpaceRemotingResult

The result of the remote invocation. Note, null value might mean that remote service returned null/void, but it also might means that there might be an SpaceRemotingResult.getException().

Specified by:

getResult in interface SpaceRemotingResult

setResult

protected void setResult(Object result)

getException

public Throwable getException()

Description copied from interface: SpaceRemotingResult

An exception that occured during the remote invocation. null value means there was no exception.

Specified by:

getException in interface SpaceRemotingResult

setException

protected void setException(Throwable exception)

getInstanceId

public Integer getInstanceId()

Description copied from interface: SpaceRemotingResult

The cluster instance id this result was executed on.

Specified by:

getInstanceId in interface SpaceRemotingResult

setInstanceId

public void setInstanceId(Integer instanceId)

Specified by:

setInstanceId in interface SpaceRemotingEntry

buildInvocation

public SpaceRemotingEntry buildInvocation(String lookupName,
                                          String methodName,
                                          Object[] arguments)

buildResultTemplate

public SpaceRemotingEntry buildResultTemplate()

Specified by:

buildResultTemplate in interface SpaceRemotingEntry

buildResult

public SpaceRemotingEntry buildResult(Throwable e)

Specified by:

buildResult in interface SpaceRemotingEntry

buildResult

public SpaceRemotingEntry buildResult(Object result)

Specified by:

buildResult in interface SpaceRemotingEntry

clone

public Object clone()
             throws CloneNotSupportedException

Specified by:

clone in interface SpaceRemotingEntry

Overrides:

clone in class Object

Throws:

CloneNotSupportedException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class Object