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
ConstructorDescriptionHvlLogProcessorMQKafkaServiceImpl
(tr.com.havelsan.javarch.kafka.notifier.HvlEventNotifier eventNotifier) Instantiates a new HvlLogProcessorMQKafkaServiceImpl. -
Method Summary
Modifier and TypeMethodDescriptionvoid
sendLog
(@NotBlank String topicName, @NotNull HvlEventLogModel event) Sent log to the message queue.
-
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 interfaceHvlLogProcessorMQService
- Parameters:
topicName
- the topic nameevent
- the event- Throws:
tr.com.havelsan.javarch.kafka.exception.HvlKafkaConnectionException
tr.com.havelsan.javarch.kafka.exception.HvlKafkaProducerException
-