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

Class HvlEventRoleGroupKafkaConsumer

java.lang.Object

tr.com.havelsan.javarch.oauth.event.starter.module.role.consumer.kafka.HvlEventRoleGroupKafkaConsumer

All Implemented Interfaces:

HvlEventConsumer<HvlOAuthRoleGroupOperationInfoEventModel>

@Component
@ConditionalOnProperty(prefix="hvl.oauth.event.role-group",
                       name="enabled")
public class HvlEventRoleGroupKafkaConsumer
extends Object
implements HvlEventConsumer<HvlOAuthRoleGroupOperationInfoEventModel>

Kafka consumer for Role Group Notification Events.

Constructor Summary

Constructors

Constructor	Description
HvlEventRoleGroupKafkaConsumer(HvlOAuthRoleGroupManager roleGroupManager, HvlOAuthRoleManager roleManager, HvlOAuthProfileRoleGroupRelManager profileRoleGroupRelManager, HvlOAuthEventNotifier eventNotifier, HvlEventRoleGroupProperties roleGroupEventProperties, HvlEventTopicProperties eventTopicProperties)	Instantiates a new HvlEventRoleGroupKafkaConsumer.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

HvlEventRoleGroupKafkaConsumer

public HvlEventRoleGroupKafkaConsumer(HvlOAuthRoleGroupManager roleGroupManager,
 HvlOAuthRoleManager roleManager,
 HvlOAuthProfileRoleGroupRelManager profileRoleGroupRelManager,
 HvlOAuthEventNotifier eventNotifier,
 HvlEventRoleGroupProperties roleGroupEventProperties,
 HvlEventTopicProperties eventTopicProperties)

Instantiates a new HvlEventRoleGroupKafkaConsumer.

Parameters:

roleGroupManager - the role group manager

roleManager - the role manager

profileRoleGroupRelManager - the profile role group rel manager

eventNotifier - the event notifier

roleGroupEventProperties - the role group event properties

eventTopicProperties - the event topic properties

Method Details

consumeLog

@KafkaListener(topics="${hvl.oauth.event.role-group.topic}")
public void consumeLog(@NotNull
 @NotNull HvlOAuthRoleGroupOperationInfoEventModel eventModel)

Consume event log.

Specified by:

consumeLog in interface HvlEventConsumer<HvlOAuthRoleGroupOperationInfoEventModel>

Parameters:

eventModel - the event model