org.springframework.kafka.support.converter

Class KafkaMessageHeaders

java.lang.Object

org.springframework.messaging.MessageHeaders

org.springframework.kafka.support.converter.KafkaMessageHeaders

All Implemented Interfaces:

java.io.Serializable, java.util.Map<java.lang.String,java.lang.Object>

public class KafkaMessageHeaders
extends org.springframework.messaging.MessageHeaders

Overload of message headers configurable for adding id and timestamp headers.

Since:

1.1

Author:

Marius Bogoevici, Gary Russell

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

java.util.Map.Entry<K,V>

Field Summary

Fields inherited from class org.springframework.messaging.MessageHeaders

CONTENT_TYPE, ERROR_CHANNEL, ID, ID_VALUE_NONE, REPLY_CHANNEL, TIMESTAMP

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Object>	getRawHeaders()

Methods inherited from class org.springframework.messaging.MessageHeaders

clear, containsKey, containsValue, entrySet, equals, get, get, getErrorChannel, getId, getIdGenerator, getReplyChannel, getTimestamp, hashCode, isEmpty, keySet, put, putAll, remove, size, toString, values

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

Method Detail

getRawHeaders

public java.util.Map<java.lang.String,java.lang.Object> getRawHeaders()

Overrides:

getRawHeaders in class org.springframework.messaging.MessageHeaders