Spring与Java集成的错误处理Dsl

我想知道在SI Java Dsl中使用serviceActivators来处理错误的正确方法是什么。我有这样的Spring集成XML配置：Spring与Java集成的错误处理Dsl

<jms:message-driven-channel-adapter id="messageIn" auto-startup="false" 
            container="messageNotificationJms" channel="messageChannel" 
            error-channel="customErrorChannel"/> 

<channel id="messageChannel"/> 

<chain input-channel="messageChannel"> 
    <!-- some logic and service-activator --> 
</chain> 

<channel id="customErrorChannelTpm"/> 

<chain input-channel="customErrorChannel" output-channel="nullChannel"> 
    <service-activator ref="errorService" method="stopEndpoints" /> 
</chain>

但现在，我想使用SI的Java DSL配置此背景下，所以我创造这样的配置

@Configuration 
@EnableIntegration 
public class SIConfig { 

    @Autowired 
    AbstractMessageListenerContainer messageNotificationJms; 

    @Autowired 
    ErrorService errorService; 

    @Bean 
    public MessageChannel messageChannel() { 
     return MessageChannels.direct("messageChannel").get(); 
    } 

    @Bean 
    public MessageChannel customErrorChannel() { 
     return MessageChannels.direct("customErrorChannel").get(); 
    } 

    @Bean 
    public JmsMessageDrivenChannelAdapter messageIn() { 
     return Jms.messageDriverChannelAdapter(messageNotificationJms) 
       .id("messageIn") 
       .autoStartup(false) 
       .outputChannel(messageChannel()) 
       .errorChannel(customErrorChannel()) 
       .get(); 
    } 


    @Bean 
    public IntegrationFlow customErrorFlow() { 
     return IntegrationFlows.from(customErrorChannel()) 
      //.handle() ????????????????????????? 
     .get(); 
    } 

    @Bean 
    public IntegrationFlow messageFlow() { 
     //some logic 
    } 

}

为抓手方法的参数我尝试使用这样的lambda表达式

.handle(message -> errorService.stopEndpoints(message))

但是由于参数类型和返回类型而出现编译错误。

我有一个非显而易见的变体，没有编译错误，但我不确定它能在环境中正常工作。它是正确的吗？：

.<ErrorMessage>handle((payload, headers) -> { 
    errorService.stopEndpoints(payload); 
    return null; 
})

另外，我的ErrorHandler类。

@Component 
public class ErrorService implements ErrorHandler { 

    @Override 
    public void handleError(Throwable t) { 
     stopEndpoints(t); 
    } 

    public void stopEndpoints(ErrorMessage errorMessage) { 
     Throwable throwable = errorMessage.getPayload(); 
     stopEndpoints(throwable); 

    } 

    private void stopEndpoints(Throwable t) { 
     //stoppingEndpoints 
    } 

}

编辑：我使用Spring框架4.1.6，Spring集成4.1.3和SI的Java DSL 1.0.1

来源

2015-05-28 Bujaka

可以使用handle(String beanName, String methodName)变种：

handle("errorService", "stopEndpoints");

或

handle("errorService", "handleError");

在第二种情况下，框架将负责解包有效负载。

来源

2015-05-28 13:28:39

Spring与Java集成的错误处理Dsl

回答

相关问题