org.zodiac.rocketmq.client

类 RocketMQClientTemplate

java.lang.Object

org.springframework.messaging.core.AbstractMessageSendingTemplate<String>

org.apache.rocketmq.spring.core.RocketMQTemplate

org.zodiac.rocketmq.client.RocketMQClientTemplate

所有已实现的接口:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.messaging.core.MessageSendingOperations<String>

public class RocketMQClientTemplate
extends org.apache.rocketmq.spring.core.RocketMQTemplate

字段概要

字段

限定符和类型	字段和说明
private ApplicationInfo	applicationInfo
private static long	DEFAULT_TIMEOUT_MILLS
protected org.slf4j.Logger	log

从类继承的字段 org.springframework.messaging.core.AbstractMessageSendingTemplate

CONVERSION_HINT_HEADER, logger

构造器概要

构造器

构造器和说明
RocketMQClientTemplate()
RocketMQClientTemplate(ApplicationInfo applicationInfo)

方法概要

限定符和类型	方法和说明
String	buildDestination(String topic, String tag)
protected <T extends BaseRocketMQMessage> org.springframework.messaging.Message<T>	buildMessage(String topic, T message)
protected String	getApplicationEnvType()
String	getApplicationName()
protected String	getApplicationRole()
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult	syncSendMessage(String topic, String tag, T message)
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult	syncSendMessage(String topic, String tag, T message, RocketMQMessageDelayLevel delayLevel)
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult	syncSendMessageDest(String topic, String destination, T message)
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult	syncSendMessageDest(String topic, String destination, T message, long timeout)
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult	syncSendMessageDest(String topic, String destination, T message, long timeoutMills, RocketMQMessageDelayLevel delayLevel)
<T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult	syncSendMessageDest(String topic, String destination, T message, RocketMQMessageDelayLevel delayLevel)

从类继承的方法 org.apache.rocketmq.spring.core.RocketMQTemplate

afterPropertiesSet, asyncSend, asyncSend, asyncSend, asyncSend, asyncSend, asyncSend, asyncSend, asyncSendOrderly, asyncSendOrderly, asyncSendOrderly, asyncSendOrderly, destroy, doConvert, doSend, getCharset, getConsumer, getMessageQueueSelector, getProducer, receive, receive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendMessageInTransaction, sendOneWay, sendOneWay, sendOneWayOrderly, sendOneWayOrderly, setAsyncSenderExecutor, setCharset, setConsumer, setMessageQueueSelector, setProducer, syncSend, syncSend, syncSend, syncSend, syncSend, syncSend, syncSend, syncSendOrderly, syncSendOrderly, syncSendOrderly, syncSendOrderly, syncSendOrderly, syncSendOrderly

从类继承的方法 org.springframework.messaging.core.AbstractMessageSendingTemplate

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter

从类继承的方法 java.lang.Object

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

字段详细资料

DEFAULT_TIMEOUT_MILLS

private static final long DEFAULT_TIMEOUT_MILLS

另请参阅:

常量字段值

log

protected final org.slf4j.Logger log

applicationInfo

private final ApplicationInfo applicationInfo

构造器详细资料

RocketMQClientTemplate

public RocketMQClientTemplate()

RocketMQClientTemplate

public RocketMQClientTemplate(ApplicationInfo applicationInfo)

方法详细资料

buildDestination

public String buildDestination(String topic,
                               String tag)

syncSendMessage

public <T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult syncSendMessage(String topic,
                                                                                                      String tag,
                                                                                                      T message)

syncSendMessageDest

public <T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult syncSendMessageDest(String topic,
                                                                                                          String destination,
                                                                                                          T message)

syncSendMessageDest

public <T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult syncSendMessageDest(String topic,
                                                                                                          String destination,
                                                                                                          T message,
                                                                                                          long timeout)

syncSendMessage

public <T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult syncSendMessage(String topic,
                                                                                                      String tag,
                                                                                                      T message,
                                                                                                      RocketMQMessageDelayLevel delayLevel)

syncSendMessageDest

public <T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult syncSendMessageDest(String topic,
                                                                                                          String destination,
                                                                                                          T message,
                                                                                                          RocketMQMessageDelayLevel delayLevel)

syncSendMessageDest

public <T extends BaseRocketMQMessage> org.apache.rocketmq.client.producer.SendResult syncSendMessageDest(String topic,
                                                                                                          String destination,
                                                                                                          T message,
                                                                                                          long timeoutMills,
                                                                                                          RocketMQMessageDelayLevel delayLevel)

getApplicationName

public String getApplicationName()

getApplicationEnvType

protected final String getApplicationEnvType()

getApplicationRole

protected final String getApplicationRole()

buildMessage

protected final <T extends BaseRocketMQMessage> org.springframework.messaging.Message<T> buildMessage(String topic,
                                                                                                      T message)