Class CompositeProducerListener<K,V>
- java.lang.Object
-
- org.springframework.kafka.support.CompositeProducerListener<K,V>
-
- Type Parameters:
K- the key type.V- the value type.
- All Implemented Interfaces:
ProducerListener<K,V>
public class CompositeProducerListener<K,V> extends java.lang.Object implements ProducerListener<K,V>
AProducerListenerthat delegates to a collection of listeners.- Since:
- 2.1.6
-
-
Constructor Summary
Constructors Constructor Description CompositeProducerListener(ProducerListener<K,V>... delegates)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddDelegate(ProducerListener<K,V> delegate)protected java.util.List<ProducerListener<K,V>>getDelegates()voidonError(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, java.lang.Exception exception)Invoked after an attempt to send a message has failed.voidonSuccess(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, org.apache.kafka.clients.producer.RecordMetadata recordMetadata)Invoked after the successful send of a message (that is, after it has been acknowledged by the broker).booleanremoveDelegate(ProducerListener<K,V> delegate)voidsetDelegates(ProducerListener<K,V>... delegates)
-
-
-
Constructor Detail
-
CompositeProducerListener
@SafeVarargs public CompositeProducerListener(ProducerListener<K,V>... delegates)
-
-
Method Detail
-
setDelegates
@SafeVarargs public final void setDelegates(ProducerListener<K,V>... delegates)
-
getDelegates
protected java.util.List<ProducerListener<K,V>> getDelegates()
-
addDelegate
public void addDelegate(ProducerListener<K,V> delegate)
-
removeDelegate
public boolean removeDelegate(ProducerListener<K,V> delegate)
-
onSuccess
public void onSuccess(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, org.apache.kafka.clients.producer.RecordMetadata recordMetadata)
Description copied from interface:ProducerListenerInvoked after the successful send of a message (that is, after it has been acknowledged by the broker).- Specified by:
onSuccessin interfaceProducerListener<K,V>- Parameters:
producerRecord- the actual sent recordrecordMetadata- the result of the successful send operation
-
onError
public void onError(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, java.lang.Exception exception)
Description copied from interface:ProducerListenerInvoked after an attempt to send a message has failed.- Specified by:
onErrorin interfaceProducerListener<K,V>- Parameters:
producerRecord- the failed recordexception- the exception thrown
-
-