File tree Expand file tree Collapse file tree 1 file changed +0
-16
lines changed
spring-kafka/src/test/java/org/springframework/kafka/config Expand file tree Collapse file tree 1 file changed +0
-16
lines changed Original file line number Diff line number Diff line change @@ -221,22 +221,6 @@ protected RetryTopicComponentFactory createComponentFactory() {
221
221
then (factory ).should (never ()).setTaskExecutor (taskExecutorMock );
222
222
}
223
223
224
- @ Test
225
- void testCreatesTaskExecutorIfTimingAdjustmentEnabled () {
226
- RetryTopicComponentFactory componentFactory = mock (RetryTopicComponentFactory .class );
227
- ThreadPoolTaskExecutor taskExecutorMock = mock (ThreadPoolTaskExecutor .class );
228
- given (componentFactory .taskExecutor ()).willReturn (taskExecutorMock );
229
- RetryTopicConfigurationSupport support = new RetryTopicConfigurationSupport () {
230
- @ Override
231
- protected RetryTopicComponentFactory createComponentFactory () {
232
- return componentFactory ;
233
- }
234
- };
235
- TaskExecutor taskExecutor = support .backoffManagerTaskExecutor ();
236
- then (componentFactory ).should ().taskExecutor ();
237
- assertThat (taskExecutor ).isEqualTo (taskExecutorMock );
238
- }
239
-
240
224
@ Test
241
225
void testCreatesTaskExecutor () {
242
226
RetryTopicConfigurationSupport support = new RetryTopicConfigurationSupport ();
You can’t perform that action at this time.
0 commit comments