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

Class HvlEventProxyKafkaConsumer

java.lang.Object

tr.com.havelsan.javarch.oauth.event.starter.module.proxy.consumer.kafka.HvlEventProxyKafkaConsumer

All Implemented Interfaces:

HvlEventConsumer<HvlOAuthProxyOperationInfoEventModel>

@Component
@ConditionalOnProperty(prefix="hvl.oauth.event.proxy",
                       name="enabled")
public class HvlEventProxyKafkaConsumer
extends Object
implements HvlEventConsumer<HvlOAuthProxyOperationInfoEventModel>

Kafka consumer for Proxy Events.

Constructor Summary

Constructors

Constructor	Description
HvlEventProxyKafkaConsumer(HvlOAuthProxyManager proxyManager, HvlOAuthRoleManager roleManager, HvlOAuthUserDetailManager userDetailManager, HvlOAuthAuthorityManager authorityManager, HvlOAuthEventNotifier eventNotifier, HvlEventProxyProperties proxyEventProperties, HvlEventTopicProperties eventTopicProperties)	Instantiates a new HvlEventProxyKafkaConsumer.

Method Summary

Modifier and Type	Method	Description
void	consumeLog(@NotNull HvlOAuthProxyOperationInfoEventModel proxyOperationInfoEventModel)	Consume event log.

Methods inherited from class java.lang.Object

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

Constructor Details

HvlEventProxyKafkaConsumer

public HvlEventProxyKafkaConsumer(HvlOAuthProxyManager proxyManager,
 HvlOAuthRoleManager roleManager,
 HvlOAuthUserDetailManager userDetailManager,
 HvlOAuthAuthorityManager authorityManager,
 HvlOAuthEventNotifier eventNotifier,
 HvlEventProxyProperties proxyEventProperties,
 HvlEventTopicProperties eventTopicProperties)

Instantiates a new HvlEventProxyKafkaConsumer.

Parameters:

proxyManager - the proxy manager

roleManager - the role manager

userDetailManager - the user detail manager

authorityManager - the authority manager

eventNotifier - the event notifier

proxyEventProperties - the proxy event properties

eventTopicProperties - the event topic properties,

Method Details

consumeLog

@KafkaListener(topics="${hvl.oauth.event.proxy.topic}")
public void consumeLog(@NotNull
 @NotNull HvlOAuthProxyOperationInfoEventModel proxyOperationInfoEventModel)

Consume event log.

Specified by:

consumeLog in interface HvlEventConsumer<HvlOAuthProxyOperationInfoEventModel>

Parameters:

proxyOperationInfoEventModel - the event model