Package es.kukenan.smartfi.microservice.smartficore.controller

Class KafkaController

java.lang.Object
es.kukenan.smartfi.kafka.controller.AbstractKafkaController<es.kukenan.smartfi.events.common.AbstractEvent>
es.kukenan.smartfi.microservice.smartficore.controller.KafkaController
@Component @KafkaListener(id="${spring.kafka.consumer.group-id}", topics="${topic.exchange.name}") public class KafkaController extends es.kukenan.smartfi.kafka.controller.AbstractKafkaController<es.kukenan.smartfi.events.common.AbstractEvent>
Kafka Events handle controller.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private OnboardingService
    onboardingService
    The service that will handle onboarding events.
    private UserService
    userService
    The service that will handle user events.

  • Constructor Summary

    Constructors
    Constructor
    Description
    KafkaController()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    consume(es.kukenan.smartfi.microservice.clients.events.updated.UserUpdatedEvent userUpdatedEvent)
    Method to use for update users event.
    void
    consume(es.kukenan.smartfi.microservice.onboarding.events.modified.initiated.OnboardingInitiatedEvent event)
    Method that is invoked when a OnboardingInitiatedEvent is consumed from the service queue.
    void
    consume(es.kukenan.smartfi.microservice.onboarding.events.modified.updated.OnboardingUpdatedEvent event)
    Method that is invoked when a OnboardingUpdatedEvent is consumed from the service queue.
    void
    unknown(Object object)
    Default not handled event.

    Methods inherited from class es.kukenan.smartfi.kafka.controller.AbstractKafkaController

    publish

    Methods inherited from class java.lang.Object

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

  • Field Details

    • onboardingService

      @Autowired private OnboardingService onboardingService
      The service that will handle onboarding events.

    • userService

      @Autowired private UserService userService
      The service that will handle user events.

  • Constructor Details

    • KafkaController

      public KafkaController()

  • Method Details

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.onboarding.events.modified.initiated.OnboardingInitiatedEvent event)
      Method that is invoked when a OnboardingInitiatedEvent is consumed from the service queue.
      Parameters:
      event - OnboardingInitiatedEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.onboarding.events.modified.updated.OnboardingUpdatedEvent event)
      Method that is invoked when a OnboardingUpdatedEvent is consumed from the service queue.
      Parameters:
      event - OnboardingUpdatedEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.clients.events.updated.UserUpdatedEvent userUpdatedEvent)
      Method to use for update users event.
      Parameters:
      userUpdatedEvent - event.

    • unknown

      @KafkaHandler(isDefault=true) public void unknown(Object object)
      Default not handled event.
      Parameters:
      object - all events object.