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

Class LocalClusterReplicationSink

java.lang.Object

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

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

All Implemented Interfaces:

IIncomingReplicationFacadeProvider, IReplicationNodePluginFacade

public class LocalClusterReplicationSink
extends ReplicationGatewayComponent
implements IReplicationNodePluginFacade, IIncomingReplicationFacadeProvider

Since:

8.0.3

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	LocalClusterReplicationSink.DelegatedConnection

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.ReplicationGatewayComponent

_finderService, _lookupParametersTemplate, _registrationService, _serviceExporter

Constructor Summary

Constructors

Constructor and Description
LocalClusterReplicationSink(LocalClusterReplicationSinkConfig config)

Method Summary

Modifier and Type	Method and Description
<T> T	accept(AbstractReplicationPacket<T> packet)
void	bootstrapFromRemoteSink(BootstrapConfig bootstrapConfig)
void	close()
protected String	createPrimaryMemberRoutingUrl(String remoteSinkUrl, String primaryMember)
protected SpaceSynchronizeReplicaRequestContext	createReplicaRequestContext(String remoteSinkGatewayName, String remoteSinkUrl, int concurrentConsumers, int fetchBatchSize, boolean primaryBackupGroup, boolean hasMirror, int partition, String primaryMember)
protected String	createSpaceUrlForMember(String memberName)
String	dumpState()
void	enableIncomingReplication()
IIncomingReplicationFacade	getIncomingReplicationFacade()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.ReplicationGatewayComponent

createRegistrationService

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalClusterReplicationSink

public LocalClusterReplicationSink(LocalClusterReplicationSinkConfig config)

Method Detail

getIncomingReplicationFacade

public IIncomingReplicationFacade getIncomingReplicationFacade()

Specified by:

getIncomingReplicationFacade in interface IIncomingReplicationFacadeProvider

enableIncomingReplication

public void enableIncomingReplication()

close

public void close()

bootstrapFromRemoteSink

public void bootstrapFromRemoteSink(BootstrapConfig bootstrapConfig)
                             throws Exception

Throws:

Exception

createReplicaRequestContext

protected SpaceSynchronizeReplicaRequestContext createReplicaRequestContext(String remoteSinkGatewayName,
                                                                            String remoteSinkUrl,
                                                                            int concurrentConsumers,
                                                                            int fetchBatchSize,
                                                                            boolean primaryBackupGroup,
                                                                            boolean hasMirror,
                                                                            int partition,
                                                                            String primaryMember)

createPrimaryMemberRoutingUrl

protected String createPrimaryMemberRoutingUrl(String remoteSinkUrl,
                                               String primaryMember)

createSpaceUrlForMember

protected String createSpaceUrlForMember(String memberName)

accept

public <T> T accept(AbstractReplicationPacket<T> packet)

Specified by:

accept in interface IReplicationNodePluginFacade

dumpState

public String dumpState()