[GitHub] [rocketmq-spring] weblqb commented on issue #364: No Implementation for DelayTimeLevel in org.apache.rocketmq.spring.support.RocketMQUtil.convertToRocketMessage

[GitBox <gi...@apache.org>]

weblqb commented on issue #364:
URL: https://github.com/apache/rocketmq-spring/issues/364#issuecomment-835250983


   > Hi Billy, RocketMQTemplate has an asyncSend(RocketMQTemplate#asyncSend(java.lang.String, org.springframework.messaging.Message<?>, org.apache.rocketmq.client.producer.SendCallback, long, int)) API to send delay messages asynchronously.
   
   But actually, there is not in v2.2 RocketMQTemplate. Here are all the asyncSend implementations: 
   
   ```java
       public void asyncSend(String destination, Message<?> message, SendCallback sendCallback, long timeout) {
           if (!Objects.isNull(message) && !Objects.isNull(message.getPayload())) {
               try {
                   org.apache.rocketmq.common.message.Message rocketMsg = RocketMQUtil.convertToRocketMessage(this.objectMapper, this.charset, destination, message);
                   this.producer.send(rocketMsg, sendCallback, timeout);
               } catch (Exception var7) {
                   log.info("asyncSend failed. destination:{}, message:{} ", destination, message);
                   throw new MessagingException(var7.getMessage(), var7);
               }
           } else {
               log.error("asyncSend failed. destination:{}, message is null ", destination);
               throw new IllegalArgumentException("`message` and `message.payload` cannot be null");
           }
       }
   
       public void asyncSend(String destination, Message<?> message, SendCallback sendCallback) {
           this.asyncSend(destination, message, sendCallback, (long)this.producer.getSendMsgTimeout());
       }
   
       public void asyncSend(String destination, Object payload, SendCallback sendCallback, long timeout) {
           Message<?> message = this.doConvert(payload, (Map)null, (MessagePostProcessor)null);
           this.asyncSend(destination, message, sendCallback, timeout);
       }
   
       public void asyncSend(String destination, Object payload, SendCallback sendCallback) {
           this.asyncSend(destination, payload, sendCallback, (long)this.producer.getSendMsgTimeout());
       }
   ```
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org