Package tr.com.havelsan.javarch.oauth.event.starter.module.profile.consumer.kafka

Class HvlEventProfileKafkaConsumer

java.lang.Object

tr.com.havelsan.javarch.oauth.event.starter.module.profile.consumer.kafka.HvlEventProfileKafkaConsumer

All Implemented Interfaces:

HvlEventConsumer<HvlOAuthProfileOperationInfoEventModel>

@Component
@ConditionalOnProperty(prefix="hvl.oauth.event.profile",
                       name="enabled")
public class HvlEventProfileKafkaConsumer
extends Object
implements HvlEventConsumer<HvlOAuthProfileOperationInfoEventModel>

Kafka consumer for Profile Events.

Constructor Summary

Constructors

Constructor	Description
HvlEventProfileKafkaConsumer(HvlOAuthProfileManager profileManager, HvlOAuthRoleManager roleManager, HvlOAuthRoleGroupManager roleGroupManager, HvlOAuthUserManager userManager, HvlOAuthAuthorityManager authorityManager, HvlOAuthEventNotifier eventNotifier, HvlEventProfileProperties profileEventProperties, HvlEventTopicProperties eventTopicProperties)	Instantiates a new HvlEventProfileKafkaConsumer.

Method Summary

Modifier and Type	Method	Description
void	consumeLog(@NotNull HvlOAuthProfileOperationInfoEventModel eventModel)	Consume event log.

Methods inherited from class java.lang.Object

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

Constructor Details

HvlEventProfileKafkaConsumer

public HvlEventProfileKafkaConsumer(HvlOAuthProfileManager profileManager,
 HvlOAuthRoleManager roleManager,
 HvlOAuthRoleGroupManager roleGroupManager,
 HvlOAuthUserManager userManager,
 HvlOAuthAuthorityManager authorityManager,
 HvlOAuthEventNotifier eventNotifier,
 HvlEventProfileProperties profileEventProperties,
 HvlEventTopicProperties eventTopicProperties)

Instantiates a new HvlEventProfileKafkaConsumer.

Parameters:

profileManager - the profile manager

roleManager - the role manager

roleGroupManager - the role group manager

userManager - the user manager

authorityManager - the authority manager

eventNotifier - the event notifier

profileEventProperties - the profile event properties

eventTopicProperties - the event topic properties

Method Details

consumeLog

@KafkaListener(topics="${hvl.oauth.event.profile.topic}")
public void consumeLog(@NotNull
 @NotNull HvlOAuthProfileOperationInfoEventModel eventModel)

Consume event log.

Specified by:

consumeLog in interface HvlEventConsumer<HvlOAuthProfileOperationInfoEventModel>

Parameters:

eventModel - the event model