Package com.gigaspaces.internal.transport

Class AbstractEntryPacket

java.lang.Object

com.gigaspaces.internal.serialization.AbstractExternalizable

com.gigaspaces.internal.transport.AbstractEntryPacket

All Implemented Interfaces:

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

Direct Known Subclasses:

AbstractQueryPacket, EntryPacket, ExternalizableEntryPacket, HybridEntryPacket, LocalCacheResponseEntryPacket, PbsEntryPacket

public abstract class AbstractEntryPacket
extends AbstractExternalizable
implements IEntryPacket, Textualizable

Author:

kimchy

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected EntryType	_entryType
protected byte	_entryTypeCode
protected ITypeDesc	_typeDesc
protected int	_typeDescChecksum

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractEntryPacket()	Default constructor required by Externalizable.
protected	AbstractEntryPacket(ITypeDesc typeDesc, EntryType entryType)

Method Summary

Modifier and Type	Method	Description
IEntryPacket	clone()
boolean	equals(Object obj)
String	getCodebase()
EntryType	getEntryType()
String	getExternalEntryImplClassName()
Object	getID()
protected Object	getIdImpl()
OperationID	getOperationID()
int	getPreviousVersion()	Gets the entry's previous version in space before update
Object	getPropertyValue(String name)
Object	getRoutingFieldValue()
int	getTypeDescChecksum()
ITypeDesc	getTypeDescriptor()
boolean	hasFixedPropertiesArray()	true if the entry packet has an array of fixed properties
int	hashCode()
boolean	hasPreviousVersion()	Gets whether this packet has a previous version set.
boolean	isExternalizableEntryPacket()
boolean	isSerializeTypeDesc()
protected void	readExternal(ObjectInput in, PlatformLogicalVersion version)
protected void	readExternalImpl(ObjectInput in)
void	readFromSwap(ObjectInput in)
void	setOperationID(OperationID operationID)
void	setPreviousVersion(int previousVersion)	Sets the entry's previous version in space before update, relevant for replication update operation
void	setPropertyValue(String name, Object value)
void	setSerializeTypeDesc(boolean serializeTypeDesc)
void	setTypeDesc(ITypeDesc typeDesc, boolean serializeTypeDesc)
boolean	supportsTypeDescChecksum()
Object	toObject(QueryResultTypeInternal resultType)
Object	toObject(QueryResultTypeInternal resultType, StorageTypeDeserialization storageTypeDeserialization)
Object	toObject(EntryType entryType)
Object	toObject(EntryType entryType, StorageTypeDeserialization storageTypeDeserialization)
String	toString()
void	toText(Textualizer textualizer)
protected void	validateStorageType()
protected void	writeExternal(ObjectOutput out, PlatformLogicalVersion version)
protected void	writeExternalImpl(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

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 java.io.Externalizable

readExternal, writeExternal

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

allNullFieldValues, getTTL, isHybrid, setCustomQuery, setTTL, setUID

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

getCustomQuery, getDynamicProperties, getFieldValue, getFieldValues, getMultipleUIDs, getPacketType, getTypeName, getUID, getVersion, isFifo, isNoWriteLease, isTransient, setDynamicProperties, setFieldsValues, setFieldValue, setMultipleUIDs, setVersion

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Field Details

_typeDesc

protected ITypeDesc _typeDesc

_typeDescChecksum

protected int _typeDescChecksum

_entryType

protected EntryType _entryType

_entryTypeCode

protected transient byte _entryTypeCode

Constructor Details

AbstractEntryPacket

protected AbstractEntryPacket()

Default constructor required by Externalizable.

AbstractEntryPacket

protected AbstractEntryPacket(ITypeDesc typeDesc,
 EntryType entryType)

Method Details

clone

public IEntryPacket clone()

Specified by:

clone in interface IEntryPacket

Overrides:

clone in class Object

toString

public String toString()

Overrides:

toString in class Object

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getEntryType

public EntryType getEntryType()

Specified by:

getEntryType in interface ITransportPacket

getExternalEntryImplClassName

public String getExternalEntryImplClassName()

Specified by:

getExternalEntryImplClassName in interface ITransportPacket

getOperationID

public OperationID getOperationID()

Specified by:

getOperationID in interface ITransportPacket

setOperationID

public void setOperationID(OperationID operationID)

Specified by:

setOperationID in interface ITransportPacket

getTypeDescriptor

public ITypeDesc getTypeDescriptor()

Specified by:

getTypeDescriptor in interface ITransportPacket

setTypeDesc

public void setTypeDesc(ITypeDesc typeDesc,
 boolean serializeTypeDesc)

Specified by:

setTypeDesc in interface ITransportPacket

getTypeDescChecksum

public int getTypeDescChecksum()

Specified by:

getTypeDescChecksum in interface ITransportPacket

supportsTypeDescChecksum

public boolean supportsTypeDescChecksum()

Specified by:

supportsTypeDescChecksum in interface ITransportPacket

isSerializeTypeDesc

public boolean isSerializeTypeDesc()

Specified by:

isSerializeTypeDesc in interface ITransportPacket

setSerializeTypeDesc

public void setSerializeTypeDesc(boolean serializeTypeDesc)

Specified by:

setSerializeTypeDesc in interface ITransportPacket

getCodebase

public String getCodebase()

Specified by:

getCodebase in interface ITransportPacket

getPropertyValue

public Object getPropertyValue(String name)

Specified by:

getPropertyValue in interface ITransportPacket

setPropertyValue

public void setPropertyValue(String name,
 Object value)

Specified by:

setPropertyValue in interface ITransportPacket

getID

public Object getID()

Specified by:

getID in interface IEntryPacket

getIdImpl

protected Object getIdImpl()

getPreviousVersion

public int getPreviousVersion()

Description copied from interface: IEntryPacket

Gets the entry's previous version in space before update

Specified by:

getPreviousVersion in interface IEntryPacket

setPreviousVersion

public void setPreviousVersion(int previousVersion)

Description copied from interface: IEntryPacket

Sets the entry's previous version in space before update, relevant for replication update operation

Specified by:

setPreviousVersion in interface IEntryPacket

hasPreviousVersion

public boolean hasPreviousVersion()

Description copied from interface: IEntryPacket

Gets whether this packet has a previous version set.

Specified by:

hasPreviousVersion in interface IEntryPacket

getRoutingFieldValue

public Object getRoutingFieldValue()

Specified by:

getRoutingFieldValue in interface ITransportPacket

toObject

public Object toObject(QueryResultTypeInternal resultType)

Specified by:

toObject in interface ITransportPacket

toObject

public Object toObject(QueryResultTypeInternal resultType,
 StorageTypeDeserialization storageTypeDeserialization)

Specified by:

toObject in interface ITransportPacket

hasFixedPropertiesArray

public boolean hasFixedPropertiesArray()

true if the entry packet has an array of fixed properties

Specified by:

hasFixedPropertiesArray in interface IEntryPacket

toObject

public Object toObject(EntryType entryType)

Specified by:

toObject in interface ITransportPacket

toObject

public Object toObject(EntryType entryType,
 StorageTypeDeserialization storageTypeDeserialization)

Specified by:

toObject in interface ITransportPacket

writeExternalImpl

protected void writeExternalImpl(ObjectOutput out)
                          throws IOException

Overrides:

writeExternalImpl in class AbstractExternalizable

Throws:

IOException

readExternalImpl

protected void readExternalImpl(ObjectInput in)
                         throws IOException,
ClassNotFoundException

Overrides:

readExternalImpl in class AbstractExternalizable

Throws:

IOException

ClassNotFoundException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Throws:

IOException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Throws:

IOException

ClassNotFoundException

writeExternal

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

Throws:

IOException

readExternal

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

Throws:

IOException

ClassNotFoundException

validateStorageType

protected void validateStorageType()

isExternalizableEntryPacket

public boolean isExternalizableEntryPacket()

Specified by:

isExternalizableEntryPacket in interface IEntryPacket