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

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

Fields

Modifier and Type	Field	Description
static final String	USER_KAFKA_TOPIC

Constructor Summary

Constructors

Constructor	Description
HvlEventUserKafkaConsumer(HvlOAuthUserManager userManager, HvlOAuthEventNotifier eventNotifier, HvlEventUserProperties userEventProperties, HvlEventTopicProperties eventTopicProperties, HvlEventKeyProperties eventKeyProperties)	Instantiates a new HvlEventUserKafkaConsumer.

Method Summary

Modifier and Type	Method	Description
void	consumeLog(@NotNull HvlOAuthUserOperationInfoEventModel userOperationInfoEventModel)	Consume event log.

Methods inherited from class java.lang.Object

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

Field Details

USER_KAFKA_TOPIC

public static final String USER_KAFKA_TOPIC

See Also:

• Constant Field Values

Constructor Details

HvlEventUserKafkaConsumer

public HvlEventUserKafkaConsumer(HvlOAuthUserManager userManager,
 HvlOAuthEventNotifier eventNotifier,
 HvlEventUserProperties userEventProperties,
 HvlEventTopicProperties eventTopicProperties,
 HvlEventKeyProperties eventKeyProperties)

Instantiates a new HvlEventUserKafkaConsumer.

Parameters:

userManager - the user manager

eventNotifier - the event notifier

userEventProperties - the user event properties

eventTopicProperties - the event topic properties

eventKeyProperties - 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 interface HvlEventConsumer<HvlOAuthUserOperationInfoEventModel>

Parameters:

userOperationInfoEventModel - the event model