我正在使用int:request-handler-advice-chain我的服务激活器。它可以正常工作，org.springframework.retry.policy.SimpleRetryPolicy但是我想org.springframework.retry.policy.ExceptionClassifierRetryPolicy根据服务激活器抛出的异常允许不同次数的重试。
我遇到的问题是，当异常到达时，ExceptionClassifierRetryPolicy它是
org.springframework.integration.MessageHandlingException
MessageHandlingException任何人都可以建议从提供给的原因（即我的例外）的最佳方法ExceptionClassifierRetryPolicy？
解决方案感谢 Artem 的以下建议：
创建一个 SubclassClassifier 的子类，在 MessagingException 的情况下返回原因
public class MessagingCauseExtractingSubclassClassifier extends SubclassClassifier<Throwable, RetryPolicy> {
private static final Logger LOG = LoggerFactory.getLogger(MessagingCauseExtractingSubclassClassifier.class);
public MessagingCauseExtractingSubclassClassifier(final Map<Class<? extends Throwable>, RetryPolicy> policyMap, final RetryPolicy retryPolicy) {
super(policyMap, retryPolicy);
}
@Override
public RetryPolicy classify(final Throwable throwable) {
Throwable t = throwable;
if (t instanceof MessagingException) {
t = t.getCause();
LOG.debug("Throwable is instanceof MessagingException so classifying cause type: {}", t.getClass());
}
return super.classify(t);
}
}
然后是一个新的 ExceptionClassifierRetryPolicy 子类，它使用新的分类器和 policyMap
public class MessasgeCauseExtractingExceptionClassifierRetryPolicy extends ExceptionClassifierRetryPolicy {
@Override
public void setPolicyMap(final Map<Class<? extends Throwable>, RetryPolicy> policyMap) {
final MessagingCauseExtractingSubclassClassifier classifier = new MessagingCauseExtractingSubclassClassifier(
policyMap, new NeverRetryPolicy());
setExceptionClassifier(classifier);
}
}
目前这不支持在 MessagingException 上重新绑定，但这对我们的用例来说很好。否则完美运行。