com.gigaspaces.internal.transport

Class PbsEntryPacket

java.lang.Object

com.gigaspaces.internal.serialization.AbstractExternalizable

com.gigaspaces.internal.transport.AbstractEntryPacket

com.gigaspaces.internal.transport.PbsEntryPacket

All Implemented Interfaces:

RawEntry, ISwapExternalizable, IEntryPacket, ITransportPacket, Textualizable, SmartExternalizable, Externalizable, Serializable, Cloneable

Direct Known Subclasses:

PbsTemplatePacket

public class PbsEntryPacket
extends AbstractEntryPacket

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected String	_className
protected Object[]	_fieldsValues
protected Object	_routingFieldValue
protected byte	_unmarshContentState
protected static byte	CONTENT_ALL
protected static byte	CONTENT_HEADER
protected static byte	CONTENT_NONE

Fields inherited from class com.gigaspaces.internal.transport.AbstractEntryPacket

_entryType, _entryTypeCode, _typeDesc, _typeDescChecksum

Constructor Summary

Constructors

Constructor and Description
PbsEntryPacket()
PbsEntryPacket(byte[] byteStream, Map<String,Object> dynamicProperties, EntryType entryType)
PbsEntryPacket(ITypeDesc typeDesc, EntryType entryType)
PbsEntryPacket(ITypeDesc typeDesc, EntryType entryType, Object[] fixedProperties, Map<String,Object> dynamicProperties, String uid, int version, long timeToLive, boolean isTransient)
PbsEntryPacket(PbsInputStream input, ITypeDesc typeDesc, EntryType entryType)

Method Summary

Modifier and Type	Method and Description
IEntryPacket	clone()
ICustomQuery	getCustomQuery()
Map<String,Object>	getDynamicProperties()
Object	getFieldValue(int index)
Object[]	getFieldValues()
String[]	getMultipleUIDs()
TransportPacketType	getPacketType()
Object	getRoutingFieldValue()
byte[]	getStreamBytes()
long	getTTL()
int	getTypeDescChecksum()
String	getTypeName()
String	getUID()
int	getVersion()
boolean	hasFixedPropertiesArray() true if the entry packet has an array of fixed properties
boolean	isFifo()
boolean	isNoWriteLease()
boolean	isReturnOnlyUids()
boolean	isTransient()
protected void	readExternal(ObjectInput in, PlatformLogicalVersion version)
void	readFromSwap(ObjectInput in)
void	setCustomQuery(ICustomQuery customQuery)
void	setDynamicProperties(Map<String,Object> dynamicProperties)
void	setFieldsValues(Object[] values)
void	setFieldValue(int index, Object value)
void	setMultipleUIDs(String[] multipleUIDs)
void	setReturnOnlyUIDs(boolean returnOnlyUIDs)
void	setTTL(long ttl)
void	setUID(String uid)
void	setVersion(int version)
boolean	supportsTypeDescChecksum()
protected void	writeExternal(ObjectOutput out, PlatformLogicalVersion version)
void	writeToSwap(ObjectOutput out)

Methods inherited from class com.gigaspaces.internal.transport.AbstractEntryPacket

equals, getCodebase, getEntryType, getExternalEntryImplClassName, getID, getIdImpl, getOperationID, getPreviousVersion, getPropertyValue, getTypeDescriptor, hashCode, hasPreviousVersion, isExternalizableEntryPacket, isSerializeTypeDesc, readExternalImpl, setOperationID, setPreviousVersion, setPropertyValue, setSerializeTypeDesc, setTypeDesc, toObject, toObject, toObject, toObject, toString, toText, validateStorageType, writeExternalImpl

Methods inherited from class com.gigaspaces.internal.serialization.AbstractExternalizable

readExternal, writeExternal

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.gigaspaces.internal.transport.IEntryPacket

allNullFieldValues, isHybrid

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Field Detail

CONTENT_NONE

protected static final byte CONTENT_NONE

See Also:

Constant Field Values

CONTENT_HEADER

protected static final byte CONTENT_HEADER

See Also:

Constant Field Values

CONTENT_ALL

protected static final byte CONTENT_ALL

See Also:

Constant Field Values

_className

protected String _className

_fieldsValues

protected Object[] _fieldsValues

_unmarshContentState

protected byte _unmarshContentState

_routingFieldValue

protected Object _routingFieldValue

Constructor Detail

PbsEntryPacket

public PbsEntryPacket()

PbsEntryPacket

public PbsEntryPacket(ITypeDesc typeDesc,
                      EntryType entryType)

PbsEntryPacket

public PbsEntryPacket(PbsInputStream input,
                      ITypeDesc typeDesc,
                      EntryType entryType)

PbsEntryPacket

public PbsEntryPacket(byte[] byteStream,
                      Map<String,Object> dynamicProperties,
                      EntryType entryType)

PbsEntryPacket

public PbsEntryPacket(ITypeDesc typeDesc,
                      EntryType entryType,
                      Object[] fixedProperties,
                      Map<String,Object> dynamicProperties,
                      String uid,
                      int version,
                      long timeToLive,
                      boolean isTransient)

Method Detail

clone

public IEntryPacket clone()

Specified by:

clone in interface IEntryPacket

Overrides:

clone in class AbstractEntryPacket

getStreamBytes

public byte[] getStreamBytes()

getPacketType

public TransportPacketType getPacketType()

getMultipleUIDs

public String[] getMultipleUIDs()

setMultipleUIDs

public void setMultipleUIDs(String[] multipleUIDs)

isReturnOnlyUids

public boolean isReturnOnlyUids()

setReturnOnlyUIDs

public void setReturnOnlyUIDs(boolean returnOnlyUIDs)

getTTL

public long getTTL()

setTTL

public void setTTL(long ttl)

isNoWriteLease

public boolean isNoWriteLease()

getTypeName

public String getTypeName()

getUID

public String getUID()

setUID

public void setUID(String uid)

getVersion

public int getVersion()

setVersion

public void setVersion(int version)

isFifo

public boolean isFifo()

isTransient

public boolean isTransient()

getRoutingFieldValue

public Object getRoutingFieldValue()

Specified by:

getRoutingFieldValue in interface ITransportPacket

Overrides:

getRoutingFieldValue in class AbstractEntryPacket

getFieldValues

public Object[] getFieldValues()

setFieldsValues

public void setFieldsValues(Object[] values)

getDynamicProperties

public Map<String,Object> getDynamicProperties()

setDynamicProperties

public void setDynamicProperties(Map<String,Object> dynamicProperties)

getFieldValue

public Object getFieldValue(int index)

setFieldValue

public void setFieldValue(int index,
                          Object value)

supportsTypeDescChecksum

public boolean supportsTypeDescChecksum()

Specified by:

supportsTypeDescChecksum in interface ITransportPacket

Overrides:

supportsTypeDescChecksum in class AbstractEntryPacket

getTypeDescChecksum

public int getTypeDescChecksum()

Specified by:

getTypeDescChecksum in interface ITransportPacket

Overrides:

getTypeDescChecksum in class AbstractEntryPacket

getCustomQuery

public ICustomQuery getCustomQuery()

setCustomQuery

public void setCustomQuery(ICustomQuery customQuery)

hasFixedPropertiesArray

public boolean hasFixedPropertiesArray()

true if the entry packet has an array of fixed properties

Specified by:

hasFixedPropertiesArray in interface IEntryPacket

Overrides:

hasFixedPropertiesArray in class AbstractEntryPacket

readExternal

protected void readExternal(ObjectInput in,
                            PlatformLogicalVersion version)
                     throws IOException,
                            ClassNotFoundException

Overrides:

readExternal in class AbstractEntryPacket

Throws:

IOException

ClassNotFoundException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Overrides:

writeToSwap in class AbstractEntryPacket

Throws:

IOException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap in class AbstractEntryPacket

Throws:

IOException

ClassNotFoundException

writeExternal

protected void writeExternal(ObjectOutput out,
                             PlatformLogicalVersion version)
                      throws IOException

Overrides:

writeExternal in class AbstractEntryPacket

Throws:

IOException