Я пытаюсь написать другой декоратор, такой как RetriableProcessorDecorator
ниже (как отдельный класс), чтобы он выполнял экспоненциальную задержку при повторной попытке. Например, если сообщение не может быть обработано, мы ждем 1 секунду (должно быть настроено), затем 2 секунды, затем 4 секунды, затем 8 секунд, затем 16 секунд и т. д. Я бы хотел использовать поток вместо ожидания занятости, поскольку это дешевле . Я написал новый класс RetriableProcessorExponentialDecorator
, который делает это, но я не уверен, что это правильный подход.
RetriableProcessorDecorator.java:
@Slf4j
@Setter
@RequiredArgsConstructor
@AllArgsConstructor(access = AccessLevel.PACKAGE)
public class RetriableProcessorDecorator implements.
AbsMessageProcessorDecorator {
private final AbsMessageProcessor messageProcessor;
@Autowired
private AbsMessageActiveMQConfiguration configuration;
@Override
public void onMessage(AbsMessage message) throws Exception {
int executionCounter = 0;
final int maxRetries = this.configuration.getExceptionRetry() + 1;
do {
executionCounter++;
try {
this.messageProcessor.onMessage(message);
} catch (RetriableException e) {
log.info("Failed to process message. Retry #{}", executionCounter);
} catch (Exception e) {
// We don't retry on this, only RetriableException.
throw e;
}
} while (executionCounter < maxRetries);
}
}
RetriableProcessorExponentialDecorator.java (новый класс, который я реализую):
public class RetriableProcessorExponentialDecorator implements AbsMessageProcessorDecorator {
private final AbsMessageProcessor messageProcessor;
@Autowired
private AbsMessageActiveMQConfiguration configuration;
@Override
public void onMessage(AbsMessage message) throws Exception {
int executionCounter = 0;
int delayCounter = 1000;
final int maxRetries = this.configuration.getExceptionRetry() + 1;
do {
executionCounter++;
try {
this.messageProcessor.onMessage(message);
} catch (RetriableException e) {
log.info("Failed to process message. Retry #{}", executionCounter);
Thread.sleep(delayCounter);
delayCounter = delayCounter * 2;
} catch (Exception e) {
// We don't retry on this, only RetriableException.
throw e;
}
} while (executionCounter < maxRetries && delayCounter < Long.MAX_VALUE);
}
}