org.springframework.cloud.stream.binder.rocketmq

Class RocketMQMessageHeaderAccessor

java.lang.Object

org.springframework.messaging.support.MessageHeaderAccessor

org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

public class RocketMQMessageHeaderAccessor
extends org.springframework.messaging.support.MessageHeaderAccessor

Author:

Timur Valiev, Jim

Field Summary

Fields inherited from class org.springframework.messaging.support.MessageHeaderAccessor

DEFAULT_CHARSET

Constructor Summary

Constructors

Constructor and Description
RocketMQMessageHeaderAccessor()
RocketMQMessageHeaderAccessor(org.springframework.messaging.Message<?> message)

Method Summary

Modifier and Type	Method and Description
Acknowledgement	getAcknowledgement(org.springframework.messaging.Message message)
Integer	getDelayTimeLevel()
Integer	getFlag()
String	getKeys()
org.apache.rocketmq.common.message.MessageExt	getRocketMessage()
org.apache.rocketmq.client.producer.SendResult	getSendResult()
String	getTags()
Object	getTransactionalArg()
Map<String,String>	getUserProperties()
static void	putSendResult(org.springframework.integration.support.MutableMessage message, org.apache.rocketmq.client.producer.SendResult sendResult)
RocketMQMessageHeaderAccessor	withAcknowledgment(Acknowledgement acknowledgment)
RocketMQMessageHeaderAccessor	withDelayTimeLevel(Integer delayTimeLevel)
RocketMQMessageHeaderAccessor	withFlag(Integer delayTimeLevel)
RocketMQMessageHeaderAccessor	withKeys(String keys)
RocketMQMessageHeaderAccessor	withRocketMessage(org.apache.rocketmq.common.message.MessageExt message)
RocketMQMessageHeaderAccessor	withTags(String tag)
Object	withTransactionalArg(Object arg)

Methods inherited from class org.springframework.messaging.support.MessageHeaderAccessor

copyHeaders, copyHeadersIfAbsent, createAccessor, getAccessor, getAccessor, getContentType, getDetailedLogMessage, getDetailedPayloadLogMessage, getErrorChannel, getHeader, getId, getMessageHeaders, getMutableAccessor, getReplyChannel, getShortLogMessage, getShortPayloadLogMessage, getTimestamp, isModified, isMutable, isReadableContentType, isReadOnly, removeHeader, removeHeaders, setContentType, setErrorChannel, setErrorChannelName, setHeader, setHeaderIfAbsent, setImmutable, setLeaveMutable, setModified, setReplyChannel, setReplyChannelName, toMap, toMessageHeaders, toString, verifyType

Methods inherited from class java.lang.Object

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

Constructor Detail

RocketMQMessageHeaderAccessor

public RocketMQMessageHeaderAccessor()

RocketMQMessageHeaderAccessor

public RocketMQMessageHeaderAccessor(org.springframework.messaging.Message<?> message)

Method Detail

getAcknowledgement

public Acknowledgement getAcknowledgement(org.springframework.messaging.Message message)

withAcknowledgment

public RocketMQMessageHeaderAccessor withAcknowledgment(Acknowledgement acknowledgment)

getTags

public String getTags()

withTags

public RocketMQMessageHeaderAccessor withTags(String tag)

getKeys

public String getKeys()

withKeys

public RocketMQMessageHeaderAccessor withKeys(String keys)

getRocketMessage

public org.apache.rocketmq.common.message.MessageExt getRocketMessage()

withRocketMessage

public RocketMQMessageHeaderAccessor withRocketMessage(org.apache.rocketmq.common.message.MessageExt message)

getDelayTimeLevel

public Integer getDelayTimeLevel()

withDelayTimeLevel

public RocketMQMessageHeaderAccessor withDelayTimeLevel(Integer delayTimeLevel)

getFlag

public Integer getFlag()

withFlag

public RocketMQMessageHeaderAccessor withFlag(Integer delayTimeLevel)

getTransactionalArg

public Object getTransactionalArg()

withTransactionalArg

public Object withTransactionalArg(Object arg)

getSendResult

public org.apache.rocketmq.client.producer.SendResult getSendResult()

putSendResult

public static void putSendResult(org.springframework.integration.support.MutableMessage message,
                                 org.apache.rocketmq.client.producer.SendResult sendResult)

getUserProperties

public Map<String,String> getUserProperties()