Package org.springframework.pulsar.support

Interface PulsarMessageHeaderMapper

All Known Implementing Classes:
DefaultPulsarMessageHeaderMapper
public interface PulsarMessageHeaderMapper
API for Pulsar message header mapper.
Author:
Soby Chacko

  • 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.

  • Method Details

    • toHeaders

      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.
      Parameters:
      source - Pulsar message.
      target - the target headers.