Package es.kukenan.smartfi.kafka.controller

Class AbstractKafkaController<T extends es.kukenan.smartfi.events.common.AbstractEvent>

java.lang.Object

es.kukenan.smartfi.kafka.controller.AbstractKafkaController<T>

Type Parameters:

T - the event type

@PropertySource("classpath:kafka-config.properties")
@RefreshScope
public abstract class AbstractKafkaController<T extends es.kukenan.smartfi.events.common.AbstractEvent>
extends Object

Create the configuration needed to exchange requests and responses through the mail channel.

Field Summary

Fields

Modifier and Type	Field	Description
private org.springframework.kafka.core.KafkaTemplate<String,Object>	requestKafkaTemplate	Amqp properties.
private String	topic	Amqp properties.

Constructor Summary

Constructors

Constructor	Description
AbstractKafkaController()

Method Summary

Modifier and Type	Method	Description
void	publish(es.kukenan.smartfi.events.common.AbstractEvent event)	EventConsumerFactory.

Methods inherited from class java.lang.Object

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

Field Details

topic

@Value("${topic.exchange.name}")
private String topic

Amqp properties.

requestKafkaTemplate

@Autowired
@Qualifier("requestKafkaTemplate")
private org.springframework.kafka.core.KafkaTemplate<String,Object> requestKafkaTemplate

Amqp properties.

Constructor Details

AbstractKafkaController

public AbstractKafkaController()

Method Details

publish

public void publish(es.kukenan.smartfi.events.common.AbstractEvent event)

EventConsumerFactory.

Parameters:

event - Events.