Package org.openspaces.persistency.kafka

Class KafkaSpaceSynchronizationEndpointBeanFactory

java.lang.Object

org.openspaces.persistency.kafka.KafkaSpaceSynchronizationEndpointBeanFactory

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<KafkaSpaceSynchronizationEndpoint>, org.springframework.beans.factory.InitializingBean

public class KafkaSpaceSynchronizationEndpointBeanFactory
extends Object
implements org.springframework.beans.factory.FactoryBean<KafkaSpaceSynchronizationEndpoint>, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

Field Summary

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
KafkaSpaceSynchronizationEndpointBeanFactory()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
void	destroy()
protected KafkaSpaceSynchronizationEndpointConfigurer	getConfigurer()
KafkaSpaceSynchronizationEndpoint	getObject()
Class<?>	getObjectType()
boolean	isSingleton()
void	setKafkaBootstrapServers(String kafkaBootstrapServers)
void	setKafkaProperties(Properties kafkaProperties)
void	setPrimaryEndpoint(SpaceSynchronizationEndpoint synchronizationEndpoint)
void	setSecondaryEndpoints(Map<String,SpaceSynchronizationEndpoint> secondaryEndpoints)
void	setTopic(String topic)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaSpaceSynchronizationEndpointBeanFactory

public KafkaSpaceSynchronizationEndpointBeanFactory()

Method Details

getConfigurer

protected KafkaSpaceSynchronizationEndpointConfigurer getConfigurer()

getObject

public KafkaSpaceSynchronizationEndpoint getObject()

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<KafkaSpaceSynchronizationEndpoint>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<KafkaSpaceSynchronizationEndpoint>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<KafkaSpaceSynchronizationEndpoint>

setPrimaryEndpoint

public void setPrimaryEndpoint(SpaceSynchronizationEndpoint synchronizationEndpoint)

setSecondaryEndpoints

public void setSecondaryEndpoints(Map<String,SpaceSynchronizationEndpoint> secondaryEndpoints)

setKafkaProperties

public void setKafkaProperties(Properties kafkaProperties)

setKafkaBootstrapServers

public void setKafkaBootstrapServers(String kafkaBootstrapServers)

setTopic

public void setTopic(String topic)

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

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

Throws:

Exception