Skip to content

Y
yzg-util
Commit 5ff8c42a authored by yanzg's avatar yanzg
Browse files
Options

修改MQ请求尸体，防止出错

parent aa040dfa
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MessageServiceImpl.java
View file @ 5ff8c42a
...@@ -94,8 +94,8 @@ public class MessageServiceImpl implements MessageService { ...@@ -94,8 +94,8 @@ public class MessageServiceImpl implements MessageService {
* @return * @return
*/ */
private String sendContent(String messageId, MessageVo req, boolean now) { private String sendContent(String messageId, MessageVo req, boolean now) {
if (!StringHelper.compare(req.getExchangeName(), YzgMqConsumer.YZG_MQ_SYSTEM_QUEUE_DELAY) if (!req.getExchangeName().startsWith(YzgMqConsumer.YZG_MQ_SYSTEM_QUEUE_DELAY)
&& !StringHelper.compare(req.getExchangeName(), YzgMqConsumer.YZG_MQ_SYSTEM_QUEUE)) { && !req.getExchangeName().startsWith(YzgMqConsumer.YZG_MQ_SYSTEM_QUEUE)) {
if (req.getDedTime() > 0 && !now) { if (req.getDedTime() > 0 && !now) {
// 延迟队列处理 // 延迟队列处理
req.setMessageId(messageId); req.setMessageId(messageId);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment