Package es.kukenan.smartfi.microservice.communication.controller

Class KafkaController

java.lang.Object
es.kukenan.smartfi.kafka.controller.AbstractKafkaController<es.kukenan.smartfi.events.common.AbstractEvent>
es.kukenan.smartfi.microservice.communication.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 CotPushNotificationService
    cotPushNotificationService
    The COT push notification service.
    private OnboardingDomainEventService
    eventNotificationService
    The notification service that holds the business logic.
    private FirmEventService
    firmEventService
    The signature event service.
    private NotificationCreatedEventService
    notificationCreatedEventService
    The notification created event ervice.
    private NotificationSettingService
    notificationSettingService
    The push notification service that holds the business logic.
    private ScheduledEventService
    scheduledEventService
    Scheduled event service ScheduledEventService.
    private SecurityGatewayEventService
    securityGatewayEventService
    The sevice that holds the logic of security gateway event handling.
    private TransferSuccessfulService
    transferSuccessfulService
    The transfer Successful Service.
    private UserContractDocumentEventService
    userContractDocumentEventService
    The user contract document event service.
    private UserDeviceTokenDeletedService
    userDeviceTokenDeletedService
    The user device token service that holds the business logic.
    private UserLifecycleEventService
    userLifecycleEventService
    The sevice that holds the logic of users lifecycle event handling.
    private UserPasswordResetEventService
    userPasswordResetEventService
    The user reset password event service.

  • Constructor Summary

    Constructors
    Constructor
    Description
    KafkaController()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    consume(es.kukenan.smartfi.events.scheduled.task.trigger.ScheduledTaskTriggerEvent scheduledTaskTriggerEvent)
    Consume ScheduledTaskTriggerEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.clients.events.created.UserCreatedEvent usersEvent)
    Consume UserCreatedEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.clients.events.document.UserContractDocumentEvent userContractDocumentEvent)
    Consume UserContractDocumentEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.clients.events.pwdreset.UserPasswordResetEvent userPasswordResetEvent)
    Consume UserPasswordResetEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.clients.events.tokendeleted.UserDeviceTokenDeletedEvent userDeviceTokenDeletedEvent)
    Consume @link UserDeviceTokenDeletedEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.clients.events.updated.UserUpdatedEvent usersEvent)
    Consume UserUpdatedEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.contracts.events.created.NotificationCreatedEvent notificationCreatedEvent)
    Consume NotificationCreatedEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.eventsender.events.CotPushNotificationEvent cotPushNotificationEvent)
    Consume @link CotPushNotificationEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.firm.events.ecommerce.FirmEcommerceEvent signatureEcommerceEvent)
    Consume FirmEcommerceEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.alreadyclient.OnboardingAlreadyClientEvent onboardingEvent)
    Consume OnboardingAlreadyClientEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.amlverification.OnboardingAmlVerificationPendingEvent onboardingEvent)
    Consume OnboardingAmlVerificationPendingEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.completed.OnboardingCompletedEvent onboardingEvent)
    Consume OnboardingCompletedEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.evidencesverification.OnboardingEvidencesVerificationPendingEvent onboardingEvent)
    Consume OnboardingEvidencesVerificationPendingEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.ko.OnboardingKoEvent onboardingEvent)
    Consume OnboardingKoEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.validated.OnboardingValidatedEvent onboardingEvent)
    Consume OnboardingValidatedEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.security.gateway.events.otp.OtpGeneratedEvent event)
    Consume OtpGeneratedEvent received from the messaging system.
    void
    consume(es.kukenan.smartfi.microservice.transfer.events.transfersuccesful.TransferSuccessfulEvent transferSuccessfulEvent)
    Consume @link TransferSuccessfulEvent received from the messaging system.
    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

    • eventNotificationService

      @Autowired private OnboardingDomainEventService eventNotificationService
      The notification service that holds the business logic.

    • userLifecycleEventService

      @Autowired private UserLifecycleEventService userLifecycleEventService
      The sevice that holds the logic of users lifecycle event handling.

    • securityGatewayEventService

      @Autowired private SecurityGatewayEventService securityGatewayEventService
      The sevice that holds the logic of security gateway event handling.

    • notificationSettingService

      @Autowired private NotificationSettingService notificationSettingService
      The push notification service that holds the business logic.

    • userDeviceTokenDeletedService

      @Autowired private UserDeviceTokenDeletedService userDeviceTokenDeletedService
      The user device token service that holds the business logic.

    • cotPushNotificationService

      @Autowired private CotPushNotificationService cotPushNotificationService
      The COT push notification service.

    • firmEventService

      @Autowired private FirmEventService firmEventService
      The signature event service.

    • notificationCreatedEventService

      @Autowired private NotificationCreatedEventService notificationCreatedEventService
      The notification created event ervice.

    • userPasswordResetEventService

      @Autowired private UserPasswordResetEventService userPasswordResetEventService
      The user reset password event service.

    • userContractDocumentEventService

      @Autowired private UserContractDocumentEventService userContractDocumentEventService
      The user contract document event service.

    • scheduledEventService

      @Autowired private ScheduledEventService scheduledEventService
      Scheduled event service ScheduledEventService.

    • transferSuccessfulService

      @Autowired private TransferSuccessfulService transferSuccessfulService
      The transfer Successful Service.

  • Constructor Details

    • KafkaController

      public KafkaController()

  • Method Details

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.ko.OnboardingKoEvent onboardingEvent)
      Consume OnboardingKoEvent received from the messaging system.
      Parameters:
      onboardingEvent - OnboardingKoEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.validated.OnboardingValidatedEvent onboardingEvent)
      Consume OnboardingValidatedEvent received from the messaging system.
      Parameters:
      onboardingEvent - OnboardingValidatedEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.completed.OnboardingCompletedEvent onboardingEvent)
      Consume OnboardingCompletedEvent received from the messaging system.
      Parameters:
      onboardingEvent - OnboardingCompletedEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.alreadyclient.OnboardingAlreadyClientEvent onboardingEvent)
      Consume OnboardingAlreadyClientEvent received from the messaging system.
      Parameters:
      onboardingEvent - OnboardingAlreadyClientEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.amlverification.OnboardingAmlVerificationPendingEvent onboardingEvent)
      Consume OnboardingAmlVerificationPendingEvent received from the messaging system.
      Parameters:
      onboardingEvent - OnboardingAmlVerificationPendingEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.onboarding.events.statuschanged.evidencesverification.OnboardingEvidencesVerificationPendingEvent onboardingEvent)
      Consume OnboardingEvidencesVerificationPendingEvent received from the messaging system.
      Parameters:
      onboardingEvent - OnboardingEvidencesVerificationPendingEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.clients.events.created.UserCreatedEvent usersEvent)
      Consume UserCreatedEvent received from the messaging system.
      Parameters:
      usersEvent - UserCreatedEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.clients.events.updated.UserUpdatedEvent usersEvent)
      Consume UserUpdatedEvent received from the messaging system.
      Parameters:
      usersEvent - UserUpdatedEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.security.gateway.events.otp.OtpGeneratedEvent event)
      Consume OtpGeneratedEvent received from the messaging system.
      Parameters:
      event - OtpGeneratedEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.clients.events.tokendeleted.UserDeviceTokenDeletedEvent userDeviceTokenDeletedEvent)
      Consume @link UserDeviceTokenDeletedEvent received from the messaging system.
      Parameters:
      userDeviceTokenDeletedEvent - UserDeviceTokenDeletedEvent

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.eventsender.events.CotPushNotificationEvent cotPushNotificationEvent)
      Consume @link CotPushNotificationEvent received from the messaging system.
      Parameters:
      cotPushNotificationEvent - CotPushNotificationEvent

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.contracts.events.created.NotificationCreatedEvent notificationCreatedEvent)
      Consume NotificationCreatedEvent received from the messaging system.
      Parameters:
      notificationCreatedEvent - NotificationCreatedEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.clients.events.pwdreset.UserPasswordResetEvent userPasswordResetEvent)
      Consume UserPasswordResetEvent received from the messaging system.
      Parameters:
      userPasswordResetEvent - UserPasswordResetEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.clients.events.document.UserContractDocumentEvent userContractDocumentEvent)
      Consume UserContractDocumentEvent received from the messaging system.
      Parameters:
      userContractDocumentEvent - UserContractDocumentEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.firm.events.ecommerce.FirmEcommerceEvent signatureEcommerceEvent)
      Consume FirmEcommerceEvent received from the messaging system.
      Parameters:
      signatureEcommerceEvent - FirmEcommerceEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.events.scheduled.task.trigger.ScheduledTaskTriggerEvent scheduledTaskTriggerEvent)
      Consume ScheduledTaskTriggerEvent received from the messaging system.
      Parameters:
      scheduledTaskTriggerEvent - ScheduledTaskTriggerEvent.

    • consume

      @KafkaHandler public void consume(es.kukenan.smartfi.microservice.transfer.events.transfersuccesful.TransferSuccessfulEvent transferSuccessfulEvent)
      Consume @link TransferSuccessfulEvent received from the messaging system.
      Parameters:
      transferSuccessfulEvent - TransferSuccessfulEvent

    • unknown

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