org.openspaces.core.gateway

Class GatewayTargetsFactoryBean

java.lang.Object

org.openspaces.core.gateway.GatewayTargetsFactoryBean

All Implemented Interfaces:

SpaceCustomComponentFactoryBean, org.springframework.beans.factory.InitializingBean

public class GatewayTargetsFactoryBean
extends Object
implements SpaceCustomComponentFactoryBean, org.springframework.beans.factory.InitializingBean

A factory bean for creating a GatewaysPolicy instance.

Since:

8.0.3

Author:

Idan Moyal

Constructor Summary

Constructors

Constructor and Description
GatewayTargetsFactoryBean()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
GatewaysPolicy	asGatewaysPolicy()
SpaceCustomComponent	createSpaceComponent()
List<GatewayTarget>	getGatewayTargets()
String	getLocalGatewayName()
void	setBulkSize(Integer bulkSize) Sets the number of packets in each replication bulk sent to this gateway.
void	setGatewayTargets(List<GatewayTarget> gatewayTargets) Sets the gateway targets configuration.
void	setIdleTimeThreshold(Long idleTimeThreshold) Sets the maximum time (in milliseconds) pending replication packets should wait before being replicated if setPendingOperationThreshold(Integer) has not been breached.
void	setLocalGatewayName(String localGatewayName) Sets the local gateway name used for identification.
void	setMaxRedoLogCapacity(Long maxRedoLogCapacity) Sets limited redo log capacity for this gateway
void	setOnRedoLogCapacityExceeded(RedoLogCapacityExceededPolicy onRedoLogCapacityExceeded) Sets the behavior once the defined redo log capacity is exceeded, irrelevant if the capacity is unlimited.
void	setPendingOperationThreshold(Integer pendingOperationThreshold) Sets the threshold count for pending replication packets that once reached, the packets will be replicated using the setBulkSize(Integer).
void	setReplicateChangeAsUpdate(Boolean replicateChangeAsUpdate) Sets whether change operations should be replicated as full update.

Methods inherited from class java.lang.Object

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

Constructor Detail

GatewayTargetsFactoryBean

public GatewayTargetsFactoryBean()

Method Detail

setLocalGatewayName

public void setLocalGatewayName(String localGatewayName)

Sets the local gateway name used for identification.

Parameters:

localGatewayName - The local gateway name.

getLocalGatewayName

public String getLocalGatewayName()

Returns:

The local gateway name used for identification.

getGatewayTargets

public List<GatewayTarget> getGatewayTargets()

Returns:

GatewayTargets configuration as array.

setGatewayTargets

public void setGatewayTargets(List<GatewayTarget> gatewayTargets)

Sets the gateway targets configuration.

Parameters:

gatewayTargets - The gateway targets.

setBulkSize

public void setBulkSize(Integer bulkSize)

Sets the number of packets in each replication bulk sent to this gateway.

Parameters:

bulkSize - number of packets in each replication bulk sent to this gateway.

setIdleTimeThreshold

public void setIdleTimeThreshold(Long idleTimeThreshold)

Sets the maximum time (in milliseconds) pending replication packets should wait before being replicated if setPendingOperationThreshold(Integer) has not been breached.

Parameters:

idleTimeThreshold - the maximum time (in milliseconds).

setPendingOperationThreshold

public void setPendingOperationThreshold(Integer pendingOperationThreshold)

Sets the threshold count for pending replication packets that once reached, the packets will be replicated using the setBulkSize(Integer).

Parameters:

pendingOperationThreshold - the threshold count.

See Also:

setIdleTimeThreshold(Long)

setMaxRedoLogCapacity

public void setMaxRedoLogCapacity(Long maxRedoLogCapacity)

Sets limited redo log capacity for this gateway

Parameters:

maxRedoLogCapacity - redo log limit

setOnRedoLogCapacityExceeded

public void setOnRedoLogCapacityExceeded(RedoLogCapacityExceededPolicy onRedoLogCapacityExceeded)

Sets the behavior once the defined redo log capacity is exceeded, irrelevant if the capacity is unlimited.

See Also:

setMaxRedoLogCapacity(Long)

setReplicateChangeAsUpdate

public void setReplicateChangeAsUpdate(Boolean replicateChangeAsUpdate)

Sets whether change operations should be replicated as full update.

Parameters:

replicateChangeAsUpdate - true if change should be replicated as update.

asGatewaysPolicy

public GatewaysPolicy asGatewaysPolicy()

Returns:

A new GatewaysPolicy instance using the bean's properties.

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

createSpaceComponent

public SpaceCustomComponent createSpaceComponent()

Specified by:

createSpaceComponent in interface SpaceCustomComponentFactoryBean