Spring Integration DSL过滤器代替过滤器方法注释 [英] spring integration dsl filter instead filter method annotation

问题描述

如何从过滤器注释方法切换到Spring集成Java DSL过滤器。如何调用过滤器方法？

How can I switch from filter annotation method to Spring integration java DSL filter. how can I call filter method?

IntegrationFlows.from("removeSession")
                // remove chat session from user sessions map
                .handle("sessionLogService", "removeChatSession")
                // continue and remove user from ehcache only if user have no more opened sessions.
                .filter(/* what's going here? */)
                .get();

代替过滤器注释。

@Filter(inputChannel = "userGoOfflineFilter", outputChannel = "userGoOffline")
    public boolean notifyOnlyIfLastConnectionClosed(SecureUser secureUser) {
        ChatUser user = sessionUtils.getChatUser(secureUser.getId());
        if(user == null || user.getChatSessionIds() == null || user.getChatSessionIds().isEmpty())
            return true;
        LOGGER.debug(secureUser.getFirstName()+": Offline message not sent yet");
        return false;
    }

推荐答案

有几个重载的<$ IntegrationFlowDefinition 上的c $ c> .filter（）方法。看一下javadocs，但是

There are several overloaded .filter() methods on IntegrationFlowDefinition. Take a look at the javadocs, but

filter("expression");

采用SpEL表达式。可能是bean引用，例如

takes a SpEL expression. It could be a bean reference, such as

.filter("@myFilter.notifyOnlyIfLastConnectionClosed('payload')")

或者您可以使用 GenericSelector ...

or you can use a GenericSelector...

.filter(SecureUser.class, u -> u == null || u.getChatSessionIds() == null || u.getChatSessionIds().isEmpty())

（java 8 lambda）或

(java 8 lambda) or

.filter(new GenericSelector<SecureUser>() {
                    @Override
                    public boolean accept(SecureUser u) {
                        return u == null || u.getChatSessionIds() == null || u.getChatSessionIds().isEmpty();
                    }
                })

（java 6/7）。

(java 6/7).

等。

这篇关于Spring Integration DSL过滤器代替过滤器方法注释的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！