Commit 81dff773 authored by yanzg's avatar yanzg

修复等待时间

parent 2d83610c
......@@ -16,14 +16,16 @@ import org.springframework.stereotype.Component;
@Component
public class MessageFairResend implements ThreadNext.Next, InitializingBean {
@Autowired
private MessageSendService messageSendService;
@Autowired
private MqConfig mqConfig;
private final MessageSendService messageSendService;
private final MqConfig mqConfig;
private boolean isPause = false;
public MessageFairResend(MessageSendService messageSendService, MqConfig mqConfig) {
this.messageSendService = messageSendService;
this.mqConfig = mqConfig;
}
/**
* Invoked by a BeanFactory after it has set all bean properties supplied
* (and satisfied BeanFactoryAware and ApplicationContextAware).
......
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