com.gigaspaces.lrmi.nio

Class RequestPacket

java.lang.Object

com.gigaspaces.lrmi.nio.RequestPacket

All Implemented Interfaces:

IPacket

public class RequestPacket
extends Object
implements IPacket

A Request Packet is constructed by the NIO client peer and sent to the server.

Since:

4.0

Author:

Igor Goldenberg

Field Summary

Fields

Modifier and Type	Field and Description
Exception	exception Exception during deserialization of RequestPacket of during method invocation
boolean	isCallBack
OperationPriority	operationPriority

Constructor Summary

Constructors

Constructor and Description
RequestPacket()
RequestPacket(long objectId, int methodOrderId, Object[] args, boolean isOneWay, boolean isCallBack, LRMIMethod invokeMethod, long contextClassLoaderId, OperationPriority priority, PlatformLogicalVersion targetVersion)
RequestPacket(Object requestObj)

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the RequestPacket internal state.
static OperationPriority	decodePriority(byte flags)
static byte	encodePriority(OperationPriority priority, byte flags)
Object[]	getArgs()
LRMIMethod	getInvokeMethod()
long	getObjectId()
static OperationPriority	getOperationPriorityFromBytes(byte[] bytes) Assumes internal knowledge of how the LRMI incoming invocation bytes should appear
Object	getRequestObject()
boolean	isOneWay()
void	readExternal(MarshalInputStream in)
void	restorePreviousLRMIRemoteClassLoaderState()
void	set(long objectId, int methodOrderId, Object[] args, boolean isOneWay, boolean isCallBack, LRMIMethod lrmiMethod, long contextClassLoaderId, OperationPriority priority, PlatformLogicalVersion targetVersion)
String	toString()
void	writeExternal(MarshalOutputStream out)

Methods inherited from class java.lang.Object

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

Field Detail

exception

public Exception exception

Exception during deserialization of RequestPacket of during method invocation

isCallBack

public transient boolean isCallBack

operationPriority

public transient OperationPriority operationPriority

Constructor Detail

RequestPacket

public RequestPacket()

RequestPacket

public RequestPacket(Object requestObj)

RequestPacket

public RequestPacket(long objectId,
                     int methodOrderId,
                     Object[] args,
                     boolean isOneWay,
                     boolean isCallBack,
                     LRMIMethod invokeMethod,
                     long contextClassLoaderId,
                     OperationPriority priority,
                     PlatformLogicalVersion targetVersion)

Method Detail

getInvokeMethod

public LRMIMethod getInvokeMethod()

set

public final void set(long objectId,
                      int methodOrderId,
                      Object[] args,
                      boolean isOneWay,
                      boolean isCallBack,
                      LRMIMethod lrmiMethod,
                      long contextClassLoaderId,
                      OperationPriority priority,
                      PlatformLogicalVersion targetVersion)

getRequestObject

public Object getRequestObject()

decodePriority

public static OperationPriority decodePriority(byte flags)

encodePriority

public static byte encodePriority(OperationPriority priority,
                                  byte flags)

readExternal

public void readExternal(MarshalInputStream in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface IPacket

Parameters:

in - request the input stream, MarshalInputStream is passed to allow changing the default classloader.

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(MarshalOutputStream out)
                   throws IOException

Specified by:

writeExternal in interface IPacket

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

clear

public void clear()

Clear the RequestPacket internal state.

getArgs

public Object[] getArgs()

getObjectId

public long getObjectId()

isOneWay

public boolean isOneWay()

restorePreviousLRMIRemoteClassLoaderState

public void restorePreviousLRMIRemoteClassLoaderState()

getOperationPriorityFromBytes

public static OperationPriority getOperationPriorityFromBytes(byte[] bytes)

Assumes internal knowledge of how the LRMI incoming invocation bytes should appear

Parameters:

bytes - the bytes

Returns:

operation priority

Since:

9.0