import org.springframework.retry.interceptor.RetryOperationsInterceptor; //导入依赖的package包/类
@Bean
public RetryOperationsInterceptor rabbitSourceRetryInterceptor() {
	return RetryInterceptorBuilder.stateless()
			.maxAttempts(this.properties.getMaxAttempts())
			.backOffOptions(this.properties.getInitialRetryInterval(), this.properties.getRetryMultiplier(),
					this.properties.getMaxRetryInterval())
			.recoverer(new RejectAndDontRequeueRecoverer())
			.build();
}
 

import org.springframework.retry.interceptor.RetryOperationsInterceptor; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(name = "configServerRetryInterceptor")
public RetryOperationsInterceptor configServerRetryInterceptor(
		RetryProperties properties) {
	return RetryInterceptorBuilder
			.stateless()
			.backOffOptions(properties.getInitialInterval(),
					properties.getMultiplier(), properties.getMaxInterval())
			.maxAttempts(properties.getMaxAttempts()).build();
}
 

import org.springframework.retry.interceptor.RetryOperationsInterceptor; //导入依赖的package包/类
@Bean(name = "consulRetryInterceptor")
@ConditionalOnMissingBean(name = "consulRetryInterceptor")
public RetryOperationsInterceptor consulRetryInterceptor(
		RetryProperties properties) {
	return RetryInterceptorBuilder
			.stateless()
			.backOffOptions(properties.getInitialInterval(),
					properties.getMultiplier(), properties.getMaxInterval())
			.maxAttempts(properties.getMaxAttempts()).build();
}
 

import org.springframework.retry.interceptor.RetryOperationsInterceptor; //导入依赖的package包/类
@Bean
public RetryOperationsInterceptor retryAdvice() {

	SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
	retryPolicy.setMaxAttempts(2);

	RetryTemplate retryTemplate = new RetryTemplate();
	retryTemplate.setRetryPolicy(retryPolicy);

	RetryOperationsInterceptor interceptor = new RetryOperationsInterceptor();
	interceptor.setRetryOperations(retryTemplate);

	return interceptor;
}