Index

A B C D E I K M P R S T
All Classes and Interfaces|All Packages

A

AbstractKafkaController<T extends es.kukenan.smartfi.events.common.AbstractEvent> - Class in es.kukenan.smartfi.kafka.controller

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

AbstractKafkaController() - Constructor for class es.kukenan.smartfi.kafka.controller.AbstractKafkaController

afterPropertiesSet() - Method in class es.kukenan.smartfi.kafka.repository.EventIdRepository

B

bootstrapAddress - Variable in class es.kukenan.smartfi.kafka.config.KafkaConsumerConfig

Topic exchange to publish to.

bootstrapAddress - Variable in class es.kukenan.smartfi.kafka.config.KafkaProducerConfig

Topic exchange to publish to.

bootstrapAddress - Variable in class es.kukenan.smartfi.kafka.config.TopicConfig

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

C

collectionName - Variable in class es.kukenan.smartfi.kafka.repository.EventIdRepository

The name of the eventId collection.

D

deleteAll() - Method in class es.kukenan.smartfi.kafka.repository.EventIdRepository

Remove all the eventIds in the collection.

E

es.kukenan.smartfi.kafka - package es.kukenan.smartfi.kafka

Root application package.

es.kukenan.smartfi.kafka.config - package es.kukenan.smartfi.kafka.config

Root application package.

es.kukenan.smartfi.kafka.controller - package es.kukenan.smartfi.kafka.controller

Package where common and abstract controller modules will be placed.

es.kukenan.smartfi.kafka.repository - package es.kukenan.smartfi.kafka.repository

Events repository package.

es.kukenan.smartfi.kafka.repository.model - package es.kukenan.smartfi.kafka.repository.model

Event model package.

EventId - Class in es.kukenan.smartfi.kafka.repository.model

EventId entity, represents the objects stored in the EventId collection.

EventId() - Constructor for class es.kukenan.smartfi.kafka.repository.model.EventId

eventIdCollection - Variable in class es.kukenan.smartfi.kafka.repository.EventIdRepository

The eventId collection in the Mongo database.

EventIdRepository - Class in es.kukenan.smartfi.kafka.repository

EventId repository, use to register the processed events and avoid duplicated execution.

EventIdRepository() - Constructor for class es.kukenan.smartfi.kafka.repository.EventIdRepository

eventKafkaListenerContainerFactory() - Method in class es.kukenan.smartfi.kafka.config.KafkaConsumerConfig

EventConsumerFactory.

eventProducerFactory() - Method in class es.kukenan.smartfi.kafka.config.KafkaProducerConfig

EventConsumerFactory.

eventTopic() - Method in class es.kukenan.smartfi.kafka.config.TopicConfig

EventConsumerFactory.

I

id - Variable in class es.kukenan.smartfi.kafka.repository.model.EventId

The event identifier.

indexName - Variable in class es.kukenan.smartfi.kafka.repository.EventIdRepository

The collection index required to implement the TTL.

K

kafkaAdmin() - Method in class es.kukenan.smartfi.kafka.config.TopicConfig

EventConsumerFactory.

KafkaConsumerConfig - Class in es.kukenan.smartfi.kafka.config

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

KafkaConsumerConfig() - Constructor for class es.kukenan.smartfi.kafka.config.KafkaConsumerConfig

KafkaProducerConfig - Class in es.kukenan.smartfi.kafka.config

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

KafkaProducerConfig() - Constructor for class es.kukenan.smartfi.kafka.config.KafkaProducerConfig

M

mongo - Variable in class es.kukenan.smartfi.kafka.repository.EventIdRepository

Mongo database connection factory.

multiTypeConsumerFactory() - Method in class es.kukenan.smartfi.kafka.config.KafkaConsumerConfig

EventConsumerFactory.

multiTypeConverter() - Method in class es.kukenan.smartfi.kafka.config.KafkaConsumerConfig

EventConsumerFactory.

P

publish(AbstractEvent) - Method in class es.kukenan.smartfi.kafka.controller.AbstractKafkaController

EventConsumerFactory.

R

requestKafkaTemplate - Variable in class es.kukenan.smartfi.kafka.controller.AbstractKafkaController

Amqp properties.

requestKafkaTemplate() - Method in class es.kukenan.smartfi.kafka.config.KafkaProducerConfig

EventConsumerFactory.

S

save(EventId) - Method in class es.kukenan.smartfi.kafka.repository.EventIdRepository

Store the eventId, fails if is already exists.

T

topic - Variable in class es.kukenan.smartfi.kafka.controller.AbstractKafkaController

Amqp properties.

TopicConfig - Class in es.kukenan.smartfi.kafka.config

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

TopicConfig() - Constructor for class es.kukenan.smartfi.kafka.config.TopicConfig

topicName - Variable in class es.kukenan.smartfi.kafka.config.TopicConfig

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

ttl - Variable in class es.kukenan.smartfi.kafka.repository.EventIdRepository

The time to live for collection entries.

ttlUnit - Variable in class es.kukenan.smartfi.kafka.repository.EventIdRepository

The time to live unit for collection entries.

A B C D E I K M P R S T
All Classes and Interfaces|All Packages