Только один экземпляр UniqueExpiryCallback может быть зарегистрирован в MessageGroupStore.

Question

В

    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);
    }
   ...
}

не должно быть никаких «!»войдите в предложение if путем проверки переменной uniqueExpiryCallbackPresent, потому что в этом созвездии я получаю журнал ERROR каждый раз, когда использую .aggregator () в конфигурации потока.Это 5.1.1 версия Spring-интеграции.

Answer 1

Спасибо;это уже сообщалось и исправлено на главном и будет в 5.1.2.