GigaSpaces XAP 10.0.1 API

org.openspaces.core.gateway
Class GatewaySinkFactoryBean

java.lang.Object
  extended by org.openspaces.core.gateway.AbstractGatewayComponentFactoryBean
      extended by org.openspaces.core.gateway.GatewaySinkFactoryBean
All Implemented Interfaces:
com.gigaspaces.internal.dump.InternalDumpProcessor, AdminEventListener, ProcessingUnitInstanceAddedEventListener, ClusterInfoAware, BeanLevelMergedPropertiesAware, InvocableService, ServiceDetailsProvider, Aware, BeanNameAware, DisposableBean, InitializingBean

public class GatewaySinkFactoryBean
extends AbstractGatewayComponentFactoryBean
implements DisposableBean, 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
GatewaySinkFactoryBean()
           
 
Method Summary
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

GigaSpaces XAP 10.0.1 API

Copyright © GigaSpaces.