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
ConstructorDescriptionHvlEventProfileKafkaConsumer
(HvlOAuthProfileManager profileManager, HvlOAuthRoleManager roleManager, HvlOAuthUserManager userManager, HvlOAuthEventNotifier eventNotifier, HvlEventProfileProperties profileEventProperties, HvlEventTopicProperties eventTopicProperties) Instantiates a new HvlEventProfileKafkaConsumer. -
Method Summary
Modifier and TypeMethodDescriptionvoid
consumeLog
(@NotNull HvlOAuthProfileOperationInfoEventModel eventModel) Consume event log.
-
Constructor Details
-
HvlEventProfileKafkaConsumer
public HvlEventProfileKafkaConsumer(HvlOAuthProfileManager profileManager, HvlOAuthRoleManager roleManager, HvlOAuthUserManager userManager, HvlOAuthEventNotifier eventNotifier, HvlEventProfileProperties profileEventProperties, HvlEventTopicProperties eventTopicProperties) Instantiates a new HvlEventProfileKafkaConsumer.- Parameters:
profileManager
- the profile managerroleManager
- the role manageruserManager
- the user managereventNotifier
- the event notifierprofileEventProperties
- the profile event propertieseventTopicProperties
- 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 interfaceHvlEventConsumer<HvlOAuthProfileOperationInfoEventModel>
- Parameters:
eventModel
- the event model
-