Commit 9c2d6dcc authored by 赵啸非's avatar 赵啸非

修改文件存储路径

parent 38477060
......@@ -56,7 +56,7 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
@Override
protected List<GetResponse> doPoll(long durationInMillis) {
List<GetResponse> result = queues.parallelStream()
List<GetResponse> result = queues.stream()
.map(queue -> {
try {
GetResponse getResponse = channel.basicGet(queue, true);
......
......@@ -88,7 +88,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
return new TopicPartitionInfo(Constant.UPLOAD_TOPIC + item.getDeviceCode(), null, exchangeName);
}
).collect(Collectors.toSet());
//mainConsumer.subscribe(topicPartitionInfoSet);
mainConsumer.subscribe(topicPartitionInfoSet);
topicPartitionInfoSet.stream().forEach(item -> {
log.info("消费线程订阅topic:{}", item.getTopic());
});
......
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