Commit 50110e70 authored by 赵啸非's avatar 赵啸非

修改文件存储路径

parent 9f4fa384
......@@ -40,7 +40,7 @@ import java.util.stream.Collectors;
import static com.mortals.xhx.common.model.MessageHeader.*;
//@Component
@Component
@Slf4j
public class DeviceMsgComsumerStartedService implements IApplicationStartedService {
......@@ -95,7 +95,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
this.consumersExecutor = Executors.newCachedThreadPool(IotThreadFactory.forName("消费queue线程"));
consumersExecutor.submit(() -> {
int waitTime = 10;
int waitTime = 50;
while (!stopped) {
try {
List<TbQueueMsg> messageList = new ArrayList(32);
......
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