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

Class HvlEventUserStrategyKafkaConsumer

java.lang.Object

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

All Implemented Interfaces:

HvlEventConsumer<HvlOAuthUserStrategyOperationInfoEventModel>

@Component
@ConditionalOnProperty(prefix="hvl.oauth.event.user-strategy",
                       name="enabled")
public class HvlEventUserStrategyKafkaConsumer
extends Object
implements HvlEventConsumer<HvlOAuthUserStrategyOperationInfoEventModel>

Kafka consumer for User Strategy Events.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	USER_STRATEGY_KAFKA_TOPIC	The constant USER_STRATEGY_KAFKA_TOPIC.

Constructor Summary

Constructors

Constructor	Description
HvlEventUserStrategyKafkaConsumer(HvlOAuthUserStrategyManager userStrategyManager, HvlOAuthProfileManager profileManager, HvlOAuthEventNotifier eventNotifier, HvlEventUserStrategyProperties userStrategyProperties, HvlEventTopicProperties eventTopicProperties)	Instantiates a new HvlEventUserStrategyKafkaConsumer.

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

USER_STRATEGY_KAFKA_TOPIC

public static final String USER_STRATEGY_KAFKA_TOPIC

The constant USER_STRATEGY_KAFKA_TOPIC.

See Also:

• Constant Field Values

Constructor Details

HvlEventUserStrategyKafkaConsumer

public HvlEventUserStrategyKafkaConsumer(HvlOAuthUserStrategyManager userStrategyManager,
 HvlOAuthProfileManager profileManager,
 HvlOAuthEventNotifier eventNotifier,
 HvlEventUserStrategyProperties userStrategyProperties,
 HvlEventTopicProperties eventTopicProperties)

Instantiates a new HvlEventUserStrategyKafkaConsumer.

Parameters:

userStrategyManager - the user strategy manager

profileManager - the profile manager

eventNotifier - the event notifier

userStrategyProperties - the user strategy properties

eventTopicProperties - the event topic properties

Method Details

consumeLog

@KafkaListener(topics="${hvl.oauth.event.user-strategy.topic}")
public void consumeLog(@NotNull
 @NotNull HvlOAuthUserStrategyOperationInfoEventModel eventModel)

Consume event log.

Specified by:

consumeLog in interface HvlEventConsumer<HvlOAuthUserStrategyOperationInfoEventModel>

Parameters:

eventModel - the event model