Package com.example.atleastonce.producer

Class LanguagePreferenceProducer

java.lang.Object

com.example.atleastonce.producer.LanguagePreferenceProducer

@Service
public class LanguagePreferenceProducer
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TOPIC

Constructor Summary

Constructors

Constructor	Description
LanguagePreferenceProducer(org.springframework.kafka.core.KafkaTemplate<String,LanguagePreference> kafkaTemplate)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<org.springframework.kafka.support.SendResult<String,LanguagePreference>>	publish(LanguagePreference event)
CompletableFuture<org.springframework.kafka.support.SendResult<String,LanguagePreference>>	publishFallback(LanguagePreference event, Throwable t)

Methods inherited from class java.lang.Object

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

Field Details

TOPIC

public static final String TOPIC

See Also:

• Constant Field Values

Constructor Details

LanguagePreferenceProducer

public LanguagePreferenceProducer(org.springframework.kafka.core.KafkaTemplate<String,LanguagePreference> kafkaTemplate)

Method Details

publish

@Retry(name="languagePreferenceProducer")
@CircuitBreaker(name="languagePreferenceProducer",
                fallbackMethod="publishFallback")
public CompletableFuture<org.springframework.kafka.support.SendResult<String,LanguagePreference>> publish(LanguagePreference event)

publishFallback

public CompletableFuture<org.springframework.kafka.support.SendResult<String,LanguagePreference>> publishFallback(LanguagePreference event,
 Throwable t)