Package es.kukenan.smartfi.microservice.clients.controller

Class KafkaController

java.lang.Object
es.kukenan.smartfi.kafka.controller.AbstractKafkaController<es.kukenan.smartfi.events.common.AbstractEvent>
es.kukenan.smartfi.microservice.clients.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 BackofficeMonitorUserCreatedService
    backofficeMonitorUserCreatedService
    THe service that will handle backoffice events.
    private BackofficeMonitorUserUpdatedService
    backofficeMonitorUserUpdatedService
    THe service that will handle backoffice updated events.
    private UserEventService
    userEventService
    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.backoffice.events.created.BackOfficeUserCreatedEvent backOfficeUserCreatedEvent)
    Method to use the back office validated event.
    void
    consume(es.kukenan.smartfi.microservice.backoffice.events.update.BackOfficeUserUpdatedEvent backOfficeUserUpdatedEvent)
    Method in charge to consume the UserUpdatedEvent.
    void
    consume(es.kukenan.smartfi.microservice.clients.events.created.UserCreationErrorEvent event)
    Method that is invoked when a UserCreationErrorEvent is consumed from the service queue.
    void
    consume(es.kukenan.smartfi.microservice.security.gateway.events.sca.UserDeviceScaUpdatedEvent userDeviceScaUpdatedEvent)
    Method to use the security gateway for update sca date.
    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

    • backofficeMonitorUserCreatedService

      @Autowired private BackofficeMonitorUserCreatedService backofficeMonitorUserCreatedService
      THe service that will handle backoffice events.

    • backofficeMonitorUserUpdatedService

      @Autowired private BackofficeMonitorUserUpdatedService backofficeMonitorUserUpdatedService
      THe service that will handle backoffice updated events.

    • userEventService

      @Autowired private UserEventService userEventService
      The service that will handle user events.

  • Constructor Details

    • KafkaController

      public KafkaController()

  • Method Details

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.backoffice.events.created.BackOfficeUserCreatedEvent backOfficeUserCreatedEvent)
      Method to use the back office validated event.
      Parameters:
      backOfficeUserCreatedEvent - event.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.backoffice.events.update.BackOfficeUserUpdatedEvent backOfficeUserUpdatedEvent)
      Method in charge to consume the UserUpdatedEvent.
      Parameters:
      backOfficeUserUpdatedEvent - event.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.security.gateway.events.sca.UserDeviceScaUpdatedEvent userDeviceScaUpdatedEvent)
      Method to use the security gateway for update sca date.
      Parameters:
      userDeviceScaUpdatedEvent - event.

    • consume

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

    • unknown

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