Package com.onec.kafka

Class OutboxRelay

java.lang.Object

com.onec.kafka.OutboxRelay

public class OutboxRelay
extends Object

Constructor Summary

Constructors

Constructor	Description
OutboxRelay(OutboxWriter outboxWriter, org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate, com.fasterxml.jackson.databind.ObjectMapper objectMapper, OnecKafkaProperties properties)

Method Summary

Modifier and Type	Method	Description
int	relayPending()

Methods inherited from class java.lang.Object

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

Constructor Details

OutboxRelay

public OutboxRelay(OutboxWriter outboxWriter,
 org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 OnecKafkaProperties properties)

Method Details

relayPending

public int relayPending()