com.gigaspaces.internal.cluster.node.impl.packets

Class BatchReplicatedDataPacket

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.router.AbstractReplicationPacket<T>

com.gigaspaces.internal.cluster.node.impl.router.AbstractGroupNameReplicationPacket<Object>

com.gigaspaces.internal.cluster.node.impl.packets.BatchReplicatedDataPacket

All Implemented Interfaces:

Textualizable, SmartExternalizable, Externalizable, Serializable

public class BatchReplicatedDataPacket
extends AbstractGroupNameReplicationPacket<Object>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BatchReplicatedDataPacket()
BatchReplicatedDataPacket(String groupName)

Method Summary

Modifier and Type	Method and Description
Object	accept(IIncomingReplicationFacade replicationFacade) Process the replication packet at the target side.
void	clean()
void	compressBatch(boolean containsDiscardedPacket)
List<IReplicationOrderedPacket>	decompressBatch()
List<IReplicationOrderedPacket>	getBatch()
boolean	isCompressed()
void	readExternalImpl(ObjectInput in, PlatformLogicalVersion endpointLogicalVersion)
void	setBatch(List<IReplicationOrderedPacket> batch)
String	toString()
void	toText(Textualizer textualizer)
void	writeExternalImpl(ObjectOutput out, PlatformLogicalVersion endpointLogicalVersion)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractGroupNameReplicationPacket

getGroupName, getTargetGroup, readExternal, writeExternal

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractReplicationPacket

getSourceEndpointDetails, getSourceLookupName, getSourceUniqueId, setSourceEndpointDetails, toIdString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Detail

BatchReplicatedDataPacket

public BatchReplicatedDataPacket()

BatchReplicatedDataPacket

public BatchReplicatedDataPacket(String groupName)

Method Detail

isCompressed

public boolean isCompressed()

accept

public Object accept(IIncomingReplicationFacade replicationFacade)

Description copied from class: AbstractReplicationPacket

Process the replication packet at the target side.

Specified by:

accept in class AbstractReplicationPacket<Object>

Returns:

process result

readExternalImpl

public void readExternalImpl(ObjectInput in,
                             PlatformLogicalVersion endpointLogicalVersion)
                      throws IOException,
                             ClassNotFoundException

Specified by:

readExternalImpl in class AbstractReplicationPacket<Object>

Throws:

IOException

ClassNotFoundException

writeExternalImpl

public void writeExternalImpl(ObjectOutput out,
                              PlatformLogicalVersion endpointLogicalVersion)
                       throws IOException

Specified by:

writeExternalImpl in class AbstractReplicationPacket<Object>

Throws:

IOException

setBatch

public void setBatch(List<IReplicationOrderedPacket> batch)

getBatch

public List<IReplicationOrderedPacket> getBatch()

clean

public void clean()

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

Overrides:

toText in class AbstractGroupNameReplicationPacket<Object>

compressBatch

public void compressBatch(boolean containsDiscardedPacket)

decompressBatch

public List<IReplicationOrderedPacket> decompressBatch()

toString

public String toString()

Overrides:

toString in class AbstractReplicationPacket<Object>