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

Class ConnectChannelPacket

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.ConnectChannelPacket

All Implemented Interfaces:

Textualizable, SmartExternalizable, Externalizable, Serializable

public class ConnectChannelPacket
extends AbstractGroupNameReplicationPacket<Object>

Replication packet that is used to establish replication channels between a IReplicationSourceGroup and a IReplicationTargetGroup

Since:

8.0

Author:

eitany

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ConnectChannelPacket()
ConnectChannelPacket(String groupName, RouterStubHolder routerStubHolder, ConnectChannelHandshakeRequest channelHandshakeRequest)

Method Summary

Modifier and Type	Method	Description
Object	accept(IIncomingReplicationFacade replicationFacade)	Process the replication packet at the target side.
ConnectChannelHandshakeRequest	getChannelHandshakeRequest()
RouterStubHolder	getRouterStubHolder()
void	readExternalImpl(ObjectInput in, PlatformLogicalVersion endpointLogicalVersion)
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, toString

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 Details

ConnectChannelPacket

public ConnectChannelPacket()

ConnectChannelPacket

public ConnectChannelPacket(String groupName,
 RouterStubHolder routerStubHolder,
 ConnectChannelHandshakeRequest channelHandshakeRequest)

Method Details

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

getChannelHandshakeRequest

public ConnectChannelHandshakeRequest getChannelHandshakeRequest()

getRouterStubHolder

public RouterStubHolder getRouterStubHolder()

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

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

Overrides:

toText in class AbstractGroupNameReplicationPacket<Object>