org.springframework.kafka.listener.adapter

Interface ReplyHeadersConfigurer

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ReplyHeadersConfigurer

A strategy for configuring which headers, if any, should be set in a reply message.

Since:

2.2

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
default java.util.Map<java.lang.String,java.lang.Object>	additionalHeaders() A map of additional headers to add to the reply message.
boolean	shouldCopy(java.lang.String headerName, java.lang.Object headerValue) Return true if the header should be copied to the reply message.

Method Detail

shouldCopy

boolean shouldCopy(java.lang.String headerName,
                   java.lang.Object headerValue)

Return true if the header should be copied to the reply message. KafkaHeaders.CORRELATION_ID will not be offered; it is always copied. MessageHeaders.ID and MessageHeaders.TIMESTAMP are never copied. KafkaHeaders.RECEIVED* headers are never copied.

Parameters:

headerName - the header name.

headerValue - the header value.

Returns:

true to copy.

additionalHeaders

@Nullable
default java.util.Map<java.lang.String,java.lang.Object> additionalHeaders()

A map of additional headers to add to the reply message. IMPORTANT: Any existing headers with the same name will be replaced by those returned by this method.

Returns:

the headers.