Package org.openspaces.admin.internal.gateway

Class DefaultGatewaySink

java.lang.Object

org.openspaces.admin.internal.gateway.DefaultGatewaySink

All Implemented Interfaces:

GatewaySink

public class DefaultGatewaySink
extends Object
implements GatewaySink

Since:

8.0.4

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	DefaultGatewaySink.DefaultGatewaySinkSource

Constructor Summary

Constructors

Constructor	Description
DefaultGatewaySink(DefaultGatewayProcessingUnit gatewayProcessingUnit, GatewaySinkServiceDetails sinkServiceDetails)

Method Summary

Modifier and Type	Method	Description
boolean	containsSource(String sourceGatewayName)	Returns true if this sink has a source gateway with the specified name; false otherwise.
void	enableIncomingReplication()	Enables incoming replication for this sink, only relevant if this sink GatewaySink.requiresBootstrapOnStartup() and no bootstrap was executed yet, otherwise the sink incoming replication is already enabled.
GatewayProcessingUnit	getGatewayProcessingUnit()	Returns the gateway this sink is part of.
String	getLocalSpaceUrl()	Returns the url of the space this sink is replicating in to.
GatewaySinkSource	getSourceByName(String sourceGatewayName)	Returns a gateway sink source for the specified source gateway name or null if no such gateway sink source exists.
GatewaySinkSource[]	getSources()	Returns the gateway sink sources of this sink.
boolean	requiresBootstrapOnStartup()	Returns whether this sink is configured to require a bootstrap on startup.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultGatewaySink

public DefaultGatewaySink(DefaultGatewayProcessingUnit gatewayProcessingUnit,
 GatewaySinkServiceDetails sinkServiceDetails)

Method Details

getGatewayProcessingUnit

public GatewayProcessingUnit getGatewayProcessingUnit()

Description copied from interface: GatewaySink

Returns the gateway this sink is part of.

Specified by:

getGatewayProcessingUnit in interface GatewaySink

enableIncomingReplication

public void enableIncomingReplication()

Description copied from interface: GatewaySink

Enables incoming replication for this sink, only relevant if this sink GatewaySink.requiresBootstrapOnStartup() and no bootstrap was executed yet, otherwise the sink incoming replication is already enabled.

Specified by:

enableIncomingReplication in interface GatewaySink

getSources

public GatewaySinkSource[] getSources()

Description copied from interface: GatewaySink

Returns the gateway sink sources of this sink.

Specified by:

getSources in interface GatewaySink

containsSource

public boolean containsSource(String sourceGatewayName)

Description copied from interface: GatewaySink

Returns true if this sink has a source gateway with the specified name; false otherwise.

Specified by:

containsSource in interface GatewaySink

getSourceByName

public GatewaySinkSource getSourceByName(String sourceGatewayName)

Description copied from interface: GatewaySink

Returns a gateway sink source for the specified source gateway name or null if no such gateway sink source exists.

Specified by:

getSourceByName in interface GatewaySink

requiresBootstrapOnStartup

public boolean requiresBootstrapOnStartup()

Description copied from interface: GatewaySink

Returns whether this sink is configured to require a bootstrap on startup.

Specified by:

requiresBootstrapOnStartup in interface GatewaySink

getLocalSpaceUrl

public String getLocalSpaceUrl()

Description copied from interface: GatewaySink

Returns the url of the space this sink is replicating in to.

Specified by:

getLocalSpaceUrl in interface GatewaySink