Package org.springframework.pulsar.support

Class DefaultPulsarMessageHeaderMapper

java.lang.Object

org.springframework.pulsar.support.DefaultPulsarMessageHeaderMapper

All Implemented Interfaces:

PulsarMessageHeaderMapper

public class DefaultPulsarMessageHeaderMapper
extends Object
implements PulsarMessageHeaderMapper

Implementation of PulsarMessageHeaderMapper.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
DefaultPulsarMessageHeaderMapper()

Method Summary

Modifier and Type	Method	Description
void	toHeaders(org.apache.pulsar.client.api.Message<?> source, Map<String,Object> target)	Map from the given message metadata to a map of headers for the eventual MessageHeaders.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultPulsarMessageHeaderMapper

public DefaultPulsarMessageHeaderMapper()

Method Details

toHeaders

public void toHeaders(org.apache.pulsar.client.api.Message<?> source,
 Map<String,Object> target)

Description copied from interface: PulsarMessageHeaderMapper

Map from the given message metadata to a map of headers for the eventual MessageHeaders.

Specified by:

toHeaders in interface PulsarMessageHeaderMapper

Parameters:

source - Pulsar message.

target - the target headers.