Interface PulsarMessageHeaderMapper
- All Known Implementing Classes:
DefaultPulsarMessageHeaderMapper
public interface PulsarMessageHeaderMapper
API for Pulsar message header mapper.
- Author:
- Soby Chacko
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Map from the given message metadata to a map of headers for the eventualMessageHeaders
.
-
Method Details
-
toHeaders
Map from the given message metadata to a map of headers for the eventualMessageHeaders
.- Parameters:
source
- Pulsar message.target
- the target headers.
-