Package com.lucidworks.apollo.pipeline.events

Class FusionCrudEventConfiguration

java.lang.Object

com.lucidworks.apollo.pipeline.events.FusionCrudEventConfiguration

@Configuration
@ConditionalOnClass(com.lucidworks.cloud.messaging.kafka.KafkaComponent.class)
public class FusionCrudEventConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
FusionCrudEventConfiguration()

Method Summary

Modifier and Type	Method	Description
com.lucidworks.cloud.messaging.crudevents.EventPublisher<com.lucidworks.apollo.common.models.FusionCrudEvent>	fusionCrudEventEventPublisher(com.lucidworks.cloud.messaging.kafka.KafkaComponent kafkaComponent, String appName)
com.lucidworks.cloud.messaging.crudevents.EventSubscriber<com.lucidworks.apollo.common.models.FusionCrudEvent>	fusionCrudEventEventSubscriber(com.lucidworks.cloud.messaging.kafka.KafkaComponent kafkaComponent, ScheduledExecutorService executorService, String appName)
static com.fasterxml.jackson.databind.ObjectMapper	indexObjectMapper()

Methods inherited from class java.lang.Object

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

Constructor Details

FusionCrudEventConfiguration

public FusionCrudEventConfiguration()

Method Details

indexObjectMapper

@Bean(name="indexObjectMapper")
public static com.fasterxml.jackson.databind.ObjectMapper indexObjectMapper()

fusionCrudEventEventSubscriber

@Bean
@ConditionalOnMissingBean
public com.lucidworks.cloud.messaging.crudevents.EventSubscriber<com.lucidworks.apollo.common.models.FusionCrudEvent> fusionCrudEventEventSubscriber(com.lucidworks.cloud.messaging.kafka.KafkaComponent kafkaComponent,
 ScheduledExecutorService executorService,
 @Value("${spring.application.name}")
 String appName)

fusionCrudEventEventPublisher

@Bean
@ConditionalOnMissingBean
public com.lucidworks.cloud.messaging.crudevents.EventPublisher<com.lucidworks.apollo.common.models.FusionCrudEvent> fusionCrudEventEventPublisher(com.lucidworks.cloud.messaging.kafka.KafkaComponent kafkaComponent,
 @Value("${spring.application.name}")
 String appName)