Add test for CompositeRetryListener.addListener()

This commit is contained in:
Sam Brannen
2025-06-15 15:23:43 +02:00
parent 8dc9621ad7
commit cd3ac44fb0

View File

@@ -18,6 +18,7 @@ package org.springframework.core.retry.support;
import java.util.List;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.core.retry.RetryExecution;
@@ -30,24 +31,32 @@ import static org.mockito.Mockito.verify;
* Tests for {@link CompositeRetryListener}.
*
* @author Mahmoud Ben Hassine
* @author Sam Brannen
* @since 7.0
*/
class CompositeRetryListenerTests {
private final RetryListener listener1 = mock();
private final RetryListener listener2 = mock();
private final RetryListener listener3 = mock();
private final RetryExecution retryExecution = mock();
private final CompositeRetryListener compositeRetryListener =
new CompositeRetryListener(List.of(listener1, listener2));
@BeforeEach
void addListener() {
compositeRetryListener.addListener(listener3);
}
@Test
void beforeRetry() {
compositeRetryListener.beforeRetry(retryExecution);
verify(listener1).beforeRetry(retryExecution);
verify(listener2).beforeRetry(retryExecution);
verify(listener3).beforeRetry(retryExecution);
}
@Test
@@ -57,6 +66,7 @@ class CompositeRetryListenerTests {
verify(listener1).onRetrySuccess(retryExecution, result);
verify(listener2).onRetrySuccess(retryExecution, result);
verify(listener3).onRetrySuccess(retryExecution, result);
}
@Test
@@ -66,6 +76,7 @@ class CompositeRetryListenerTests {
verify(listener1).onRetryFailure(retryExecution, exception);
verify(listener2).onRetryFailure(retryExecution, exception);
verify(listener3).onRetryFailure(retryExecution, exception);
}
@Test
@@ -75,6 +86,7 @@ class CompositeRetryListenerTests {
verify(listener1).onRetryPolicyExhaustion(retryExecution, exception);
verify(listener2).onRetryPolicyExhaustion(retryExecution, exception);
verify(listener3).onRetryPolicyExhaustion(retryExecution, exception);
}
}