我需要设置集成流,其中消息以特定的顺序进行处理。我试着用PriorityChannel来做这件事,传递比较器: public IntegrationFlow simpleIntegrationFlow() { }) .channel(
new PriorityChannel> endpointSpec.poll
我对spring集成优先级通道有一个奇怪的问题(至少我认为这是错误的地方)。: public PriorityChannel alphabetically(@Value("${inbound.sort.queue-capacity}") int capacity) {
return new PriorityChannel(capacity, Comparator.comparing(left -> ((File) left.getPayload