protected <T extends BaseRocketMQMessage> org.springframework.messaging.Message<T> |
RocketMQClientTemplate.buildMessage(String topic,
T message) |
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult |
RocketMQClientTemplate.syncSendMessage(String topic,
String tag,
T message) |
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult |
RocketMQClientTemplate.syncSendMessage(String topic,
String tag,
T message,
RocketMQMessageDelayLevel delayLevel) |
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult |
RocketMQClientTemplate.syncSendMessageDest(String topic,
String destination,
T message) |
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult |
RocketMQClientTemplate.syncSendMessageDest(String topic,
String destination,
T message,
long timeout) |
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult |
RocketMQClientTemplate.syncSendMessageDest(String topic,
String destination,
T message,
long timeoutMills,
RocketMQMessageDelayLevel delayLevel) |
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult |
RocketMQClientTemplate.syncSendMessageDest(String topic,
String destination,
T message,
RocketMQMessageDelayLevel delayLevel) |