Package kimaira.kafka

Class ProducerServiceImpl

java.lang.Object

kimaira.kafka.ProducerServiceImpl

All Implemented Interfaces:

ProducerService

@Service("producerService")
public class ProducerServiceImpl
extends Object
implements ProducerService

Constructor Summary

Constructors

Constructor	Description
ProducerServiceImpl(org.springframework.kafka.core.KafkaTemplate<String,String> template, KafkaOps kafkaOps)

Method Summary

Modifier and Type	Method	Description
void	send(String topic, kimaira.agentic.data.transfer.modal.ModalType key, String value)

Methods inherited from class java.lang.Object

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

Constructor Details

ProducerServiceImpl

public ProducerServiceImpl(org.springframework.kafka.core.KafkaTemplate<String,String> template,
 KafkaOps kafkaOps)

Method Details

send

public void send(String topic,
 kimaira.agentic.data.transfer.modal.ModalType key,
 String value)

Specified by:

send in interface ProducerService