Package com.example.atleastonce.producer
Class LanguagePreferenceProducer
java.lang.Object
com.example.atleastonce.producer.LanguagePreferenceProducer
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionLanguagePreferenceProducer(org.springframework.kafka.core.KafkaTemplate<String, LanguagePreference> kafkaTemplate) -
Method Summary
Modifier and TypeMethodDescriptionCompletableFuture<org.springframework.kafka.support.SendResult<String, LanguagePreference>> publish(LanguagePreference event) CompletableFuture<org.springframework.kafka.support.SendResult<String, LanguagePreference>> publishFallback(LanguagePreference event, Throwable t)
-
Field Details
-
TOPIC
- See Also:
-
-
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)
-