com.gigaspaces.internal.cluster.node.impl.backlog.globalorder

Class GlobalOrderReliableAsyncKeptDiscardedOrderedPacket

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.backlog.globalorder.GlobalOrderReliableAsyncKeptDiscardedOrderedPacket

All Implemented Interfaces:

IReplicationOrderedPacket, ISwapExternalizable, Externalizable, Serializable, Cloneable

public class GlobalOrderReliableAsyncKeptDiscardedOrderedPacket
extends Object
implements IReplicationOrderedPacket

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GlobalOrderReliableAsyncKeptDiscardedOrderedPacket()
GlobalOrderReliableAsyncKeptDiscardedOrderedPacket(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter)

Method Summary

Modifier and Type	Method and Description
GlobalOrderReliableAsyncKeptDiscardedOrderedPacket	clone()
IReplicationOrderedPacket	cloneWithNewData(IReplicationPacketData<?> newData) Clones the packet replacing its data with the new data
IReplicationOrderedPacket	getBeforeFilterPacket()
IReplicationPacketData<?>	getData()
long	getEndKey() return the last key for given packets - relevant to range packets - merged discarded/deleted packets
long	getKey()
int	getWeight()
boolean	isDataPacket()
boolean	isDiscardedPacket()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

GlobalOrderReliableAsyncKeptDiscardedOrderedPacket

public GlobalOrderReliableAsyncKeptDiscardedOrderedPacket()

GlobalOrderReliableAsyncKeptDiscardedOrderedPacket

public GlobalOrderReliableAsyncKeptDiscardedOrderedPacket(IReplicationOrderedPacket beforeFilter,
                                                          IReplicationOrderedPacket afterFilter)

Method Detail

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

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

getData

public IReplicationPacketData<?> getData()

Specified by:

getData in interface IReplicationOrderedPacket

Returns:

the actual packet data that is needed for the processing

getKey

public long getKey()

Specified by:

getKey in interface IReplicationOrderedPacket

getEndKey

public long getEndKey()

Description copied from interface: IReplicationOrderedPacket

return the last key for given packets - relevant to range packets - merged discarded/deleted packets

Specified by:

getEndKey in interface IReplicationOrderedPacket

isDataPacket

public boolean isDataPacket()

Specified by:

isDataPacket in interface IReplicationOrderedPacket

isDiscardedPacket

public boolean isDiscardedPacket()

Specified by:

isDiscardedPacket in interface IReplicationOrderedPacket

clone

public GlobalOrderReliableAsyncKeptDiscardedOrderedPacket clone()

Specified by:

clone in interface IReplicationOrderedPacket

Overrides:

clone in class Object

cloneWithNewData

public IReplicationOrderedPacket cloneWithNewData(IReplicationPacketData<?> newData)

Description copied from interface: IReplicationOrderedPacket

Clones the packet replacing its data with the new data

Specified by:

cloneWithNewData in interface IReplicationOrderedPacket

getWeight

public int getWeight()

Specified by:

getWeight in interface IReplicationOrderedPacket

getBeforeFilterPacket

public IReplicationOrderedPacket getBeforeFilterPacket()