org.gridgain.grid.dr.hub.sender

Class GridDrSenderHubConnectionConfiguration

java.lang.Object

org.gridgain.grid.dr.hub.sender.GridDrSenderHubConnectionConfiguration

public class GridDrSenderHubConnectionConfiguration
extends Object

Data center replication sender hub connection configuration.

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DFLT_AWAIT_ACK Default await acknowledge flag.
static GridDrReceiverHubLoadBalancingMode	DFLT_RCV_HUB_LOAD_BALANCING_MODE Default receiver hub load balancing policy.

Constructor Summary

Constructors

Constructor and Description
GridDrSenderHubConnectionConfiguration() Constructor.
GridDrSenderHubConnectionConfiguration(GridDrSenderHubConnectionConfiguration cfg) Copying constructor.

Method Summary

Methods

Modifier and Type	Method and Description
byte	getDataCenterId() Gets ID of remote data center.
byte[]	getIgnoredDataCenterIds() Gets IDs of data centers updates from which will not be replicated to this remote data center.
String	getLocalOutboundHost() Gets local network interface name form with remote data center is reachable.
String[]	getReceiverHubAddresses() Gets addresses of remote receiver hubs.
GridDrReceiverHubLoadBalancingMode	getReceiverHubLoadBalancingMode() Gets remote receiver hub load balancing policy.
boolean	isAwaitAcknowledge() Gets await acknowledge flag.
void	setAwaitAcknowledge(boolean awaitAck) Sets await acknowledge flag.
void	setDataCenterId(byte dataCenterId) Sets ID of remote data center.
void	setIgnoredDataCenterIds(byte... ignoreDataCenterIds) Sets ignored data center IDs.
void	setLocalOutboundHost(String locOutboundHost) Sets local network interface name form with remote data center is reachable.
void	setReceiverHubAddresses(String... rcvHubAddrs) Sets addresses of remote receiver hubs.
void	setReceiverHubLoadBalancingMode(GridDrReceiverHubLoadBalancingMode rcvHubLoadBalancingMode) Sets remote receiver hub load balancing policy.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_RCV_HUB_LOAD_BALANCING_MODE

public static final GridDrReceiverHubLoadBalancingMode DFLT_RCV_HUB_LOAD_BALANCING_MODE

Default receiver hub load balancing policy.

DFLT_AWAIT_ACK

public static final boolean DFLT_AWAIT_ACK

Default await acknowledge flag.

See Also:

Constant Field Values

Constructor Detail

GridDrSenderHubConnectionConfiguration

public GridDrSenderHubConnectionConfiguration()

Constructor.

GridDrSenderHubConnectionConfiguration

public GridDrSenderHubConnectionConfiguration(GridDrSenderHubConnectionConfiguration cfg)

Copying constructor.

Parameters:

cfg - Configuration to copy.

Method Detail

getDataCenterId

public byte getDataCenterId()

Gets ID of remote data center.

Returns:

ID of remote data center.

setDataCenterId

public void setDataCenterId(byte dataCenterId)

Sets ID of remote data center. See getDataCenterId() for more information.

Parameters:

dataCenterId - ID of remote data center.

getReceiverHubAddresses

public String[] getReceiverHubAddresses()

Gets addresses of remote receiver hubs.

Returns:

Addresses of remote receiver hubs.

setReceiverHubAddresses

public void setReceiverHubAddresses(String... rcvHubAddrs)

Sets addresses of remote receiver hubs. See getReceiverHubAddresses() for more information.

Parameters:

rcvHubAddrs - Addresses of remote receiver hubs.

getLocalOutboundHost

public String getLocalOutboundHost()

Gets local network interface name form with remote data center is reachable.

By default is set to null meaning that sender hub will be bound to the same interface as the grid itself (see GridConfiguration.getLocalHost())

Returns:

Local network interface name form with remote data center is reachable.

setLocalOutboundHost

public void setLocalOutboundHost(String locOutboundHost)

Sets local network interface name form with remote data center is reachable. See getLocalOutboundHost() for more information.

Parameters:

locOutboundHost - Local network interface name form with remote data center is reachable.

getReceiverHubLoadBalancingMode

public GridDrReceiverHubLoadBalancingMode getReceiverHubLoadBalancingMode()

Gets remote receiver hub load balancing policy. This policy provides balancing mechanism in case remote data center has several receiver hubs.

Defaults to DFLT_RCV_HUB_LOAD_BALANCING_MODE.

Returns:

Remote receiver hub load balancing policy.

setReceiverHubLoadBalancingMode

public void setReceiverHubLoadBalancingMode(GridDrReceiverHubLoadBalancingMode rcvHubLoadBalancingMode)

Sets remote receiver hub load balancing policy. See getReceiverHubLoadBalancingMode() for more information.

Parameters:

rcvHubLoadBalancingMode - Remote receiver hub load balancing policy.

getIgnoredDataCenterIds

public byte[] getIgnoredDataCenterIds()

Gets IDs of data centers updates from which will not be replicated to this remote data center. Use this parameter to avoid cycles in replication. For example, if you have setup your replication in a way that A replicates to B, B replicates to C, and C replicates back to A, then on C you should specify that updates from A should be ignored to avoid a cycle.

Returns:

Ignored data center IDs.

setIgnoredDataCenterIds

public void setIgnoredDataCenterIds(byte... ignoreDataCenterIds)

Sets ignored data center IDs. See getIgnoredDataCenterIds()

Parameters:

ignoreDataCenterIds - Ignored data center IDs.

isAwaitAcknowledge

public boolean isAwaitAcknowledge()

Gets await acknowledge flag. When set to true sender hub will await acknowledge for each replication batch sent to a receiver hub thus ensuring that data is stored in remote topology. If set to false, sender hub will not wait for that acknowledge. This will increase throughput at a cost of reliability.

Defaults to DFLT_AWAIT_ACK.

Returns:

Await acknowledge flag.

setAwaitAcknowledge

public void setAwaitAcknowledge(boolean awaitAck)

Sets await acknowledge flag. See isAwaitAcknowledge()

Parameters:

awaitAck - Await acknowledge flag.

toString

public String toString()

Overrides:

toString in class Object