Spring Integration-过滤器中的请求验证

Question

我正在使用Spring Integration Filter对传入消息强制执行一些验证逻辑。验证的结果需要发回消息网关调用方，以便通知请求的具体错误。

null

detailMessage = "message has been rejected in filter: bean 'validationFilter.requestValidation.filter.handler' for component 'validationFilter.requestValidation.filter'"

配置

网关

@MessagingGateway( name="processApiGateway", defaultRequestChannel = "inboundGatewayChannel")
public interface ProcessApiGateway {

    @Gateway
    Response getTransactions(Message<ServiceRequest> payload);

}

过滤器

 @Filter(inputChannel="inboundGatewayChannel", throwExceptionOnRejection = "true")
    public boolean requestValidation(Message<ServiceRequest> message) {
        try {
            LocalDate fromDate = LocalDate.parse(message.getPayload().getFromDate());
            LocalDate toDate = LocalDate.parse(message.getPayload().getToDate());
            return (Period.between(fromDate, toDate)).getMonths() <= 1;
        }
        catch (DateTimeParseException ex) {
            return false;
        }
    }

 @Bean
    public MessageChannel inboundGatewayChannel(@Qualifier("taskExecutor")TaskExecutor taskExecutor) {
        return new ExecutorChannel(taskExecutor);
    

 @Filter(inputChannel="inboundGatewayChannel", discardChannel = "filterDiscardChannel")
    public boolean requestValidation(Message<ServiceRequest> message) {
        try {
            LocalDate fromDate = LocalDate.parse(message.getPayload().getFromDate());
            LocalDate toDate = LocalDate.parse(message.getPayload().getToDate());
            return (Period.between(fromDate, toDate)).getMonths() <= 1;
        }
        catch (DateTimeParseException ex) {
            return false;
        }
    }

 @Service
public class ValidationServiceActivator {

    @ServiceActivator(inputChannel = "filterDiscardChannel")
    public Response handleDiscardMessage(Message<ServiceRequest> message) {
        //the same logic to validate discarded message
    }

}

Answer 1

如果您想返回一些自定义响应，而不是异常，那么我建议您只使用普通的@ServiceActivator，在该方法中执行验证逻辑并返回这个或那个答复。在这种情况下不需要过滤器。

看起来，即使使用DiscardChannel，仍然不足以确定问题...