com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class SinkEstablishConnectionPacket

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.gateway.sink.SinkEstablishConnectionPacket

All Implemented Interfaces:

Textualizable, Externalizable, Serializable

public class SinkEstablishConnectionPacket
extends AbstractReplicationPacket<SinkEstablishConnectionResult>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SinkEstablishConnectionPacket()
SinkEstablishConnectionPacket(String targetSpaceMemberLookupName)

Method Summary

Modifier and Type	Method and Description
SinkEstablishConnectionResult	accept(IIncomingReplicationFacade incomingReplicationFacade) Process the replication packet at the target side.
String	getTargetSpaceMemberLookupName()
protected void	readExternalImpl(ObjectInput in, PlatformLogicalVersion endpointLogicalVersion)
void	toText(Textualizer textualizer)
protected void	writeExternalImpl(ObjectOutput out, PlatformLogicalVersion endpointLogicalVersion)

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

getSourceEndpointDetails, getSourceLookupName, getSourceUniqueId, readExternal, setSourceEndpointDetails, toIdString, toString, writeExternal

Methods inherited from class java.lang.Object

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

Constructor Detail

SinkEstablishConnectionPacket

public SinkEstablishConnectionPacket()

SinkEstablishConnectionPacket

public SinkEstablishConnectionPacket(String targetSpaceMemberLookupName)

Method Detail

writeExternalImpl

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

Specified by:

writeExternalImpl in class AbstractReplicationPacket<SinkEstablishConnectionResult>

Throws:

IOException

readExternalImpl

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

Specified by:

readExternalImpl in class AbstractReplicationPacket<SinkEstablishConnectionResult>

Throws:

IOException

ClassNotFoundException

accept

public SinkEstablishConnectionResult accept(IIncomingReplicationFacade incomingReplicationFacade)

Description copied from class: AbstractReplicationPacket

Process the replication packet at the target side.

Specified by:

accept in class AbstractReplicationPacket<SinkEstablishConnectionResult>

Returns:

process result

getTargetSpaceMemberLookupName

public String getTargetSpaceMemberLookupName()

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

Overrides:

toText in class AbstractReplicationPacket<SinkEstablishConnectionResult>