Package tr.com.havelsan.javarch.log.processor.starter.job.mq.kafka

Class HvlLogProcessorMQKafkaServiceImpl

java.lang.Object

tr.com.havelsan.javarch.log.processor.starter.job.mq.kafka.HvlLogProcessorMQKafkaServiceImpl

All Implemented Interfaces:

HvlLogProcessorMQService

@Service
@Profile("kafka")
public class HvlLogProcessorMQKafkaServiceImpl
extends Object
implements HvlLogProcessorMQService

The class which implements HvlLogProcessorMQService.

Constructor Summary

Constructors

Constructor	Description
HvlLogProcessorMQKafkaServiceImpl(tr.com.havelsan.javarch.kafka.notifier.HvlEventNotifier eventNotifier)	Instantiates a new HvlLogProcessorMQKafkaServiceImpl.

Method Summary

Modifier and Type	Method	Description
void	sendLog(@NotBlank String topicName, @NotNull HvlEventLogModel event)	Sent log to the message queue.

Methods inherited from class java.lang.Object

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

Constructor Details

HvlLogProcessorMQKafkaServiceImpl

public HvlLogProcessorMQKafkaServiceImpl(tr.com.havelsan.javarch.kafka.notifier.HvlEventNotifier eventNotifier)

Instantiates a new HvlLogProcessorMQKafkaServiceImpl.

Parameters:

eventNotifier - the event notifier

Method Details

sendLog

public void sendLog(@NotBlank
 @NotBlank String topicName,
 @NotNull
 @NotNull HvlEventLogModel event)
             throws tr.com.havelsan.javarch.kafka.exception.HvlKafkaConnectionException,
tr.com.havelsan.javarch.kafka.exception.HvlKafkaProducerException

Sent log to the message queue.

Specified by:

sendLog in interface HvlLogProcessorMQService

Parameters:

topicName - the topic name

event - the event

Throws:

tr.com.havelsan.javarch.kafka.exception.HvlKafkaConnectionException

tr.com.havelsan.javarch.kafka.exception.HvlKafkaProducerException