代码之家  ›  专栏  ›  技术社区  ›  Roman

“MessageGroupStore”中只能注册一个“UniqueExpiryCallback”实例

  •  2
  • Roman  · 技术社区  · 7 年前

    在里面

        org.springframework.integration.store.AbstractMessageGroupStore {
        ...
        @Override
        public void registerMessageGroupExpiryCallback(MessageGroupCallback callback) {
            if (callback instanceof UniqueExpiryCallback) {
                boolean uniqueExpiryCallbackPresent =
                        this.expiryCallbacks.stream()
                                .anyMatch(UniqueExpiryCallback.class::isInstance);
    
                if (!uniqueExpiryCallbackPresent && this.logger.isErrorEnabled()) {
                    this.logger.error("Only one instance of 'UniqueExpiryCallback' can be registered in the " +
                            "'MessageGroupStore'. Use a separate 'MessageGroupStore' for each aggregator/resequencer.");
                }
            }
    
            this.expiryCallbacks.add(callback);
        }
       ...
    }
    

    它是spring集成的5.1.1版本。

    1 回复  |  直到 7 年前
        1
  •  2
  •   Gary Russell    7 年前

    谢谢这已报告并已修复 on master 并将在5.1.2中列出。