@FunctionalInterface
public interface ReplyHeadersConfigurer
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.
|
boolean shouldCopy(java.lang.String headerName, java.lang.Object headerValue)
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.headerName
- the header name.headerValue
- the header value.@Nullable default java.util.Map<java.lang.String,java.lang.Object> additionalHeaders()