Package tr.com.havelsan.javarch.log.producer.kafka.provider.service

Class HvlLogProducerKafkaProviderImpl

java.lang.Object

tr.com.havelsan.javarch.log.producer.kafka.provider.service.HvlLogProducerKafkaProviderImpl

All Implemented Interfaces:

HvlLogProducerKafkaProvider

@Service
public class HvlLogProducerKafkaProviderImpl
extends Object
implements HvlLogProducerKafkaProvider

A service which provides synchronous methods for logging with kafka.

Constructor Summary

Constructors

Constructor	Description
HvlLogProducerKafkaProviderImpl(tr.com.havelsan.javarch.kafka.notifier.HvlEventNotifier eventNotifier, HvlLogProducerProviderCacheService providerCacheService)	Instantiates a new HvlLogProducerKafkaProviderImpl.

Method Summary

Modifier and Type	Method	Description
void	produceSync(@NotBlank String topicName, @NotNull HvlEventLogModel eventLogModel)	Synchronous logging on kafka.

Methods inherited from class java.lang.Object

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

Constructor Details

HvlLogProducerKafkaProviderImpl

public HvlLogProducerKafkaProviderImpl(tr.com.havelsan.javarch.kafka.notifier.HvlEventNotifier eventNotifier,
 HvlLogProducerProviderCacheService providerCacheService)

Instantiates a new HvlLogProducerKafkaProviderImpl.

Parameters:

eventNotifier - the event notifier

providerCacheService - the provider cache service

Method Details

produceSync

public void produceSync(@NotBlank
 @NotBlank String topicName,
 @NotNull
 @NotNull HvlEventLogModel eventLogModel)

Synchronous logging on kafka.

Specified by:

produceSync in interface HvlLogProducerKafkaProvider

Parameters:

topicName - the topic name

eventLogModel - the event log model