com.gigaspaces.internal.cluster.node.impl.router

Class AbstractReplicationPacket<T>

java.lang.Object

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

All Implemented Interfaces:

Textualizable, SmartExternalizable, Externalizable, Serializable

Direct Known Subclasses:

AbstractGroupNameReplicationPacket, FetchEndpointDetailsPacket, NextReplicaStatePacket, PingPacket, QueryRemoteClusterTopologyPacket, ReplicaFetchDataPacket, SinkEstablishConnectionPacket

public abstract class AbstractReplicationPacket<T>
extends Object
implements SmartExternalizable, Textualizable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AbstractReplicationPacket()

Method Summary

Modifier and Type	Method and Description
abstract T	accept(IIncomingReplicationFacade incomingReplicationFacade) Process the replication packet at the target side.
ReplicationEndpointDetails	getSourceEndpointDetails()
String	getSourceLookupName()
Object	getSourceUniqueId()
void	readExternal(ObjectInput in)
protected abstract void	readExternalImpl(ObjectInput in, PlatformLogicalVersion endpointLogicalVersion)
void	setSourceEndpointDetails(ReplicationEndpointDetails sourceEndpointDetails)
String	toIdString()
String	toString()
void	toText(Textualizer textualizer)
void	writeExternal(ObjectOutput out)
protected abstract void	writeExternalImpl(ObjectOutput out, PlatformLogicalVersion endpointLogicalVersion)

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

AbstractReplicationPacket

public AbstractReplicationPacket()

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

writeExternalImpl

protected abstract void writeExternalImpl(ObjectOutput out,
                                          PlatformLogicalVersion endpointLogicalVersion)
                                   throws IOException

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readExternalImpl

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

Throws:

IOException

ClassNotFoundException

setSourceEndpointDetails

public void setSourceEndpointDetails(ReplicationEndpointDetails sourceEndpointDetails)

getSourceEndpointDetails

public ReplicationEndpointDetails getSourceEndpointDetails()

getSourceLookupName

public String getSourceLookupName()

getSourceUniqueId

public Object getSourceUniqueId()

accept

public abstract T accept(IIncomingReplicationFacade incomingReplicationFacade)

Process the replication packet at the target side.

Parameters:

sourceMemberLookupName - source of the packet

replicationNode - target replication node

Returns:

process result

toString

public String toString()

Overrides:

toString in class Object

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

toIdString

public String toIdString()