Package org.springframework.kafka.support.converter

Class KafkaMessageHeaders

java.lang.Object

org.springframework.messaging.MessageHeaders

org.springframework.kafka.support.converter.KafkaMessageHeaders

All Implemented Interfaces:

Serializable, Map<String,Object>

public class KafkaMessageHeaders
extends 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

Map.Entry<K extends Object,V extends Object>

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	Description
Map<String,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 Details

getRawHeaders

public Map<String,Object> getRawHeaders()

Overrides:

getRawHeaders in class MessageHeaders