Class HvlEventUserKafkaConsumer
java.lang.Object
tr.com.havelsan.javarch.oauth.event.starter.module.user.consumer.kafka.HvlEventUserKafkaConsumer
- All Implemented Interfaces:
HvlEventConsumer<HvlOAuthUserOperationInfoEventModel>
@Component
@ConditionalOnProperty(prefix="hvl.oauth.event.user",
name="enabled")
public class HvlEventUserKafkaConsumer
extends Object
implements HvlEventConsumer<HvlOAuthUserOperationInfoEventModel>
Kafka consumer for user events.
-
Field Summary
-
Constructor Summary
ConstructorDescriptionHvlEventUserKafkaConsumer
(HvlOAuthUserManager userManager, HvlOAuthEventNotifier eventNotifier, HvlEventUserProperties userEventProperties, HvlEventTopicProperties eventTopicProperties, HvlEventKeyProperties eventKeyProperties) Instantiates a new HvlEventUserKafkaConsumer. -
Method Summary
Modifier and TypeMethodDescriptionvoid
consumeLog
(@NotNull HvlOAuthUserOperationInfoEventModel userOperationInfoEventModel) Consume event log.
-
Field Details
-
USER_KAFKA_TOPIC
- See Also:
-
-
Constructor Details
-
HvlEventUserKafkaConsumer
public HvlEventUserKafkaConsumer(HvlOAuthUserManager userManager, HvlOAuthEventNotifier eventNotifier, HvlEventUserProperties userEventProperties, HvlEventTopicProperties eventTopicProperties, HvlEventKeyProperties eventKeyProperties) Instantiates a new HvlEventUserKafkaConsumer.- Parameters:
userManager
- the user managereventNotifier
- the event notifieruserEventProperties
- the user event propertieseventTopicProperties
- the event topic propertieseventKeyProperties
- the event key properties
-
-
Method Details
-
consumeLog
@KafkaListener(topics="${hvl.oauth.event.user.topic}") public void consumeLog(@NotNull @NotNull HvlOAuthUserOperationInfoEventModel userOperationInfoEventModel) Consume event log.- Specified by:
consumeLog
in interfaceHvlEventConsumer<HvlOAuthUserOperationInfoEventModel>
- Parameters:
userOperationInfoEventModel
- the event model
-