org.openspaces.core.gateway

Class GatewaySinkFactoryBean

java.lang.Object

org.openspaces.core.gateway.AbstractGatewayComponentFactoryBean

org.openspaces.core.gateway.GatewaySinkFactoryBean

All Implemented Interfaces:

InternalDumpProcessor, AdminEventListener, ProcessingUnitInstanceAddedEventListener, ClusterInfoAware, BeanLevelMergedPropertiesAware, InvocableService, ServiceDetailsProvider, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class GatewaySinkFactoryBean
extends AbstractGatewayComponentFactoryBean
implements org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, InvocableService, ServiceDetailsProvider

A sink factory bean for creating a LocalClusterReplicationSink which represents a gateway sink component.

Since:

8.0.3

Author:

idan

Field Summary

Fields inherited from class org.openspaces.core.gateway.AbstractGatewayComponentFactoryBean

logger

Constructor Summary

Constructors

Constructor and Description
GatewaySinkFactoryBean()

Method Summary

Modifier and Type	Method and Description
protected void	afterPropertiesSetImpl(SecurityConfig securityConfig)
protected void	destroyImpl()
protected String	dumpState()
GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean	getDistributedTransactionProcessingConfiguration() Gets distributed transaction processing configuration for the Sink component.
SinkErrorHandlingFactoryBean	getErrorHandlingConfiguration() Gets the error handling configuration instance defined for the Sink component.
protected String	getGatewayComponentTypeName()
List<GatewaySource>	getGatewaySources()
Long	getLocalSpaceLookupTimeout() Gets the lookup timeout for finding the local cluster the Sink works against.
String	getLocalSpaceUrl()
boolean	getRequiresBootstrap() Gets whether bootstrap is required for the Sink component.
ServiceDetails[]	getServicesDetails() Retruns one or more service details that the service exposes.
GatewaySinkSyncEndpointInterceptorFactoryBean	getSyncEndpointInterceptorConfiguration() Gets the synchronization endpoint interceptor configuration for the sink component.
Long	getTransactionTimeout() Gets the transaction timeout for the operations made by the Sink against the local cluster.
Object	invoke(Map<String,Object> namedArgs)
void	setDistributedTransactionProcessingConfiguration(GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean transactionProcessingConfiguration) Sets the distributed transaction processing configuration for the Sink component.
void	setErrorHandlingConfiguration(SinkErrorHandlingFactoryBean errorHandlingConfiguration) Sets the error handling configuration instance for the Sink component.
void	setGatewaySources(List<GatewaySource> gatewaySources) Sets the sink component's gateway replication sources.
void	setLocalSpaceLookupTimeout(Long lookupTimeout) Sets the lookup timeout for finding the local cluster the Sink works against.
void	setLocalSpaceUrl(String localSpaceUrl) Sets the local space URL the sink component operates against.
void	setRequiresBootstrap(boolean requiresBootstrap) Sets whether bootstrap is required for the Sink component.
void	setSyncEndpointInterceptorConfiguration(GatewaySinkSyncEndpointInterceptorFactoryBean syncEndpointInterceptorConfiguration) Sets the synchronization endpoint interceptor configuration for the sink component.
void	setTransactionTimeout(Long transactionTimeout) Sets the transaction timeout for the operations made by the Sink against the local cluster.

Methods inherited from class org.openspaces.core.gateway.AbstractGatewayComponentFactoryBean

afterPropertiesSet, destroy, getCommunicationPort, getCustomJvmProperties, getDiscoveryPort, getGatewayLookups, getLocalGatewayName, getName, isRelocateIfWrongPorts, isStartEmbeddedLus, process, processingUnitInstanceAdded, setBeanName, setClusterInfo, setCommunicationPort, setCredentialsProvider, setCustomJvmProperties, setGatewayLookups, setLocalGatewayName, setMergedBeanLevelProperties, setRelocateIfWrongPorts, setSecurityConfig, setStartEmbeddedLus, setUserDetails

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.DisposableBean

destroy

Methods inherited from interface org.springframework.beans.factory.InitializingBean

afterPropertiesSet

Constructor Detail

GatewaySinkFactoryBean

public GatewaySinkFactoryBean()

Method Detail

getLocalSpaceUrl

public String getLocalSpaceUrl()

Returns:

The local space URL the sink component operates against.

setLocalSpaceUrl

public void setLocalSpaceUrl(String localSpaceUrl)

Sets the local space URL the sink component operates against.

Parameters:

localSpaceUrl - The local space URL.

getGatewaySources

public List<GatewaySource> getGatewaySources()

Returns:

The sink component's gateway replication sources.

setGatewaySources

public void setGatewaySources(List<GatewaySource> gatewaySources)

Sets the sink component's gateway replication sources.

Parameters:

gatewaySources - The gateway replication sources.

setRequiresBootstrap

public void setRequiresBootstrap(boolean requiresBootstrap)

Sets whether bootstrap is required for the Sink component.

Parameters:

requiresBootstrap - true if bootstrap is required.

getRequiresBootstrap

public boolean getRequiresBootstrap()

Gets whether bootstrap is required for the Sink component.

Returns:

true if bootstrap is required.

setErrorHandlingConfiguration

public void setErrorHandlingConfiguration(SinkErrorHandlingFactoryBean errorHandlingConfiguration)

Sets the error handling configuration instance for the Sink component.

Parameters:

errorHandlingConfiguration - The error handling configuration instance.

getErrorHandlingConfiguration

public SinkErrorHandlingFactoryBean getErrorHandlingConfiguration()

Gets the error handling configuration instance defined for the Sink component.

Returns:

The error handling configuration instance.

getTransactionTimeout

public Long getTransactionTimeout()

Gets the transaction timeout for the operations made by the Sink against the local cluster.

Returns:

The transaction timeout in milliseconds.

setTransactionTimeout

public void setTransactionTimeout(Long transactionTimeout)

Sets the transaction timeout for the operations made by the Sink against the local cluster.

Parameters:

transactionTimeout - The transaction timeout in milliseconds.

setLocalSpaceLookupTimeout

public void setLocalSpaceLookupTimeout(Long lookupTimeout)

Sets the lookup timeout for finding the local cluster the Sink works against.

Parameters:

lookupTimeout - The lookup timeout in milliseconds.

getLocalSpaceLookupTimeout

public Long getLocalSpaceLookupTimeout()

Gets the lookup timeout for finding the local cluster the Sink works against.

Returns:

The lookup timeout in milliseconds.

getDistributedTransactionProcessingConfiguration

public GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean getDistributedTransactionProcessingConfiguration()

Gets distributed transaction processing configuration for the Sink component.

Returns:

Distributed transaction processing configuration.

setDistributedTransactionProcessingConfiguration

public void setDistributedTransactionProcessingConfiguration(GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean transactionProcessingConfiguration)

Sets the distributed transaction processing configuration for the Sink component.

Parameters:

transactionProcessingConfiguration - The distributed transaction processing configuration to set.

getSyncEndpointInterceptorConfiguration

public GatewaySinkSyncEndpointInterceptorFactoryBean getSyncEndpointInterceptorConfiguration()

Gets the synchronization endpoint interceptor configuration for the sink component.

Returns:

synchronization endpoint interceptor configuration.

setSyncEndpointInterceptorConfiguration

public void setSyncEndpointInterceptorConfiguration(GatewaySinkSyncEndpointInterceptorFactoryBean syncEndpointInterceptorConfiguration)

Sets the synchronization endpoint interceptor configuration for the sink component.

Parameters:

syncEndpointInterceptorConfiguration - the syncEndpointInterceptorConfiguration to set

afterPropertiesSetImpl

protected void afterPropertiesSetImpl(SecurityConfig securityConfig)

Specified by:

afterPropertiesSetImpl in class AbstractGatewayComponentFactoryBean

destroyImpl

protected void destroyImpl()

Specified by:

destroyImpl in class AbstractGatewayComponentFactoryBean

invoke

public Object invoke(Map<String,Object> namedArgs)

Specified by:

invoke in interface InvocableService

getServicesDetails

public ServiceDetails[] getServicesDetails()

Description copied from interface: ServiceDetailsProvider

Retruns one or more service details that the service exposes.

Specified by:

getServicesDetails in interface ServiceDetailsProvider

getGatewayComponentTypeName

protected String getGatewayComponentTypeName()

Specified by:

getGatewayComponentTypeName in class AbstractGatewayComponentFactoryBean

Returns:

The gateway component's type name.

dumpState

protected String dumpState()

Specified by:

dumpState in class AbstractGatewayComponentFactoryBean