Package com.alibaba.cloud.stream.binder.rocketmq.support

Interface RocketMQHeaderMapper

All Known Implementing Classes:
AbstractRocketMQHeaderMapper, JacksonRocketMQHeaderMapper
public interface RocketMQHeaderMapper
header value mapper for RocketMQ.
Since:
2.1.1.RELEASE
Author:
caotc

  • Method Summary

    Modifier and Type
    Method
    Description
    Map<String,String>
    fromHeaders(org.springframework.messaging.MessageHeaders headers)
    Map from the given MessageHeaders to the specified target message.
    org.springframework.messaging.MessageHeaders
    toHeaders(Map<String,String> source)
    Map from the given target message to abstracted MessageHeaders.

  • Method Details

    • fromHeaders

      Map<String,String> fromHeaders(org.springframework.messaging.MessageHeaders headers)
      Map from the given MessageHeaders to the specified target message.
      Parameters:
      headers - the abstracted MessageHeaders.
      Returns:
      the native target message.

    • toHeaders

      org.springframework.messaging.MessageHeaders toHeaders(Map<String,String> source)
      Map from the given target message to abstracted MessageHeaders.
      Parameters:
      source - the native target message.
      Returns:
      the target headers.