Package 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

  • Constructor Details

    • GatewaySinkFactoryBean

      public GatewaySinkFactoryBean()

  • Method Details

    • 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