diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/BasicAbstractMessageChannelBinderTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/BasicAbstractMessageChannelBinderTests.java index 48030dcf3..9882d85a4 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/BasicAbstractMessageChannelBinderTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/BasicAbstractMessageChannelBinderTests.java @@ -61,7 +61,7 @@ class BasicAbstractMessageChannelBinderTests { @Test @SuppressWarnings("unchecked") - public void testEndpointLifecycle() throws Exception { + public void endpointLifecycle() throws Exception { // @checkstyle:off AbstractMessageChannelBinder> binder = context .getBean(AbstractMessageChannelBinder.class); @@ -113,7 +113,7 @@ class BasicAbstractMessageChannelBinderTests { @Test @SuppressWarnings("unchecked") - public void testEndpointBinderHasRecoverer() throws Exception { + public void endpointBinderHasRecoverer() throws Exception { // @checkstyle:off ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration()) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/BinderErrorChannelTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/BinderErrorChannelTests.java index 4ad2ab160..3c92a3ae7 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/BinderErrorChannelTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/BinderErrorChannelTests.java @@ -45,7 +45,7 @@ class BinderErrorChannelTests { }; @Test - void testExceptionIsThrownWhenNoSubscribers() { + void exceptionIsThrownWhenNoSubscribers() { BinderErrorChannel channel = new BinderErrorChannel(); Assertions.assertThrows(MessageDeliveryException.class, () -> { channel.send(new GenericMessage("hello")); @@ -53,7 +53,7 @@ class BinderErrorChannelTests { } @Test - void testSubscribeUnsubscribe() { + void subscribeUnsubscribe() { BinderErrorChannel channel = new BinderErrorChannel(); DirectFieldAccessor fieldAccessor = new DirectFieldAccessor(channel); AbstractDispatcher dispatcher = (AbstractDispatcher) fieldAccessor diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/ErrorBindingTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/ErrorBindingTests.java index 88f3aae71..679aadb19 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/ErrorBindingTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/ErrorBindingTests.java @@ -40,7 +40,7 @@ import static org.assertj.core.api.Assertions.assertThat; class ErrorBindingTests { @Test - public void testConfigurationWithDefaultErrorHandler() { + public void configurationWithDefaultErrorHandler() { ApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ErrorBindingTests.ErrorConfigurationDefault.class)) @@ -61,7 +61,7 @@ class ErrorBindingTests { } @Test - void testConfigurationWithBindingSpecificErrorHandler() { + void configurationWithBindingSpecificErrorHandler() { ApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ErrorBindingTests.ErrorConfigurationWithCustomErrorHandler.class)) @@ -82,7 +82,7 @@ class ErrorBindingTests { } @Test - void testConfigurationWithoutBinderSpecificErrorHandler() { + void configurationWithoutBinderSpecificErrorHandler() { ApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NoErrorHandler.class)) .web(WebApplicationType.NONE) @@ -98,7 +98,7 @@ class ErrorBindingTests { } @Test - void testErrorBindingWithMultipleDestinationPerBinding() { + void errorBindingWithMultipleDestinationPerBinding() { new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NoErrorHandler.class)) .web(WebApplicationType.NONE) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/PollableConsumerTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/PollableConsumerTests.java index 90a19f820..46655c833 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/PollableConsumerTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/PollableConsumerTests.java @@ -81,7 +81,7 @@ class PollableConsumerTests { } @Test - void testDefaultMessageSource() { + void defaultMessageSource() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -103,7 +103,7 @@ class PollableConsumerTests { } @Test - void testSimple() { + void simpleCase() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -139,7 +139,7 @@ class PollableConsumerTests { } @Test - void testConvertSimple() { + void convertSimple() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -172,7 +172,7 @@ class PollableConsumerTests { } @Test - void testConvertSimpler() { + void convertSimpler() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -210,7 +210,7 @@ class PollableConsumerTests { @Test // @Disabled - void testConvertList() { + void convertList() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -242,7 +242,7 @@ class PollableConsumerTests { @Test // @Disabled - void testConvertMap() { + void convertMap() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -270,7 +270,7 @@ class PollableConsumerTests { } @Test - void testEmbedded() { + void embedded() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -315,7 +315,7 @@ class PollableConsumerTests { } @Test - void testErrors() { + void errors() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -366,7 +366,7 @@ class PollableConsumerTests { } @Test - void testErrorsNoRetry() { + void errorsNoRetry() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -402,7 +402,7 @@ class PollableConsumerTests { } @Test - void testRequeue() { + void requeue() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -442,7 +442,7 @@ class PollableConsumerTests { } @Test - void testRequeueWithNoAcknowledgementCallback() { + void requeueWithNoAcknowledgementCallback() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -475,7 +475,7 @@ class PollableConsumerTests { } @Test - void testRequeueFromErrorFlow() { + void requeueFromErrorFlow() { TestChannelBinder binder = createBinder(); MessageConverterConfigurer configurer = this.context .getBean(MessageConverterConfigurer.class); @@ -517,7 +517,7 @@ class PollableConsumerTests { @SuppressWarnings("unchecked") @Test - void testAutoStartupOff() { + void autoStartupOff() { TestChannelBinder binder = createBinder(); binder.setMessageSourceDelegate(new LifecycleMessageSource( () -> new GenericMessage<>("{\"foo\":\"bar\"}".getBytes()))); @@ -539,7 +539,7 @@ class PollableConsumerTests { @SuppressWarnings("unchecked") @Test - void testAutoStartupOn() { + void autoStartupOn() { TestChannelBinder binder = createBinder(); binder.setMessageSourceDelegate(new LifecycleMessageSource( () -> new GenericMessage<>("{\"foo\":\"bar\"}".getBytes()))); diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/tck/ContentTypeTckTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/tck/ContentTypeTckTests.java index 0d28dea98..b8f07a244 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/tck/ContentTypeTckTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/tck/ContentTypeTckTests.java @@ -458,7 +458,7 @@ class ContentTypeTckTests { // ====== @Test - void testWithMapInputParameter() { + void withMapInputParameter() { ApplicationContext context = new SpringApplicationBuilder( MapInputConfiguration.class).web(WebApplicationType.NONE) .run("--spring.jmx.enabled=false"); @@ -472,7 +472,7 @@ class ContentTypeTckTests { } @Test - void testWithMapPayloadParameter() { + void withMapPayloadParameter() { ApplicationContext context = new SpringApplicationBuilder( MapInputConfiguration.class).web(WebApplicationType.NONE) .run("--spring.jmx.enabled=false"); @@ -486,7 +486,7 @@ class ContentTypeTckTests { } @Test - void testWithListInputParameter() { + void withListInputParameter() { ApplicationContext context = new SpringApplicationBuilder( ListInputConfiguration.class).web(WebApplicationType.NONE) .run("--spring.jmx.enabled=false", "--debug"); @@ -501,7 +501,7 @@ class ContentTypeTckTests { @Test @Disabled // TODO fix it. We can recognize MessageHeaders and parse it out of the message properly - void testWithMessageHeadersInputParameter() { + void withMessageHeadersInputParameter() { ApplicationContext context = new SpringApplicationBuilder( MessageHeadersInputConfiguration.class).web(WebApplicationType.NONE) .run("--spring.jmx.enabled=false"); diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java index f67398b49..a5dbd709e 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java @@ -95,7 +95,7 @@ class BindingServiceTests { @SuppressWarnings({ "unchecked", "rawtypes" }) @Test - void testDefaultGroup() throws Exception { + void defaultGroup() throws Exception { BindingServiceProperties properties = new BindingServiceProperties(); Map bindingProperties = new HashMap<>(); BindingProperties props = new BindingProperties(); @@ -124,7 +124,7 @@ class BindingServiceTests { @SuppressWarnings({ "unchecked", "rawtypes" }) @Test - void testMultipleConsumerBindings() { + void multipleConsumerBindings() { BindingServiceProperties properties = new BindingServiceProperties(); Map bindingProperties = new HashMap<>(); BindingProperties props = new BindingProperties(); @@ -175,7 +175,7 @@ class BindingServiceTests { @SuppressWarnings({ "unchecked", "rawtypes" }) @Test - void testMultipleConsumerBindingsFromIndexList() throws Exception { + void multipleConsumerBindingsFromIndexList() throws Exception { BindingServiceProperties properties = new BindingServiceProperties(); Map bindingProperties = new HashMap<>(); BindingProperties props = new BindingProperties(); @@ -236,7 +236,7 @@ class BindingServiceTests { @SuppressWarnings({ "unchecked", "rawtypes" }) @Test - void testConsumerBindingWhenMultiplexingIsEnabled() throws Exception { + void consumerBindingWhenMultiplexingIsEnabled() throws Exception { BindingServiceProperties properties = new BindingServiceProperties(); Map bindingProperties = new HashMap<>(); BindingProperties props = new BindingProperties(); @@ -282,7 +282,7 @@ class BindingServiceTests { @SuppressWarnings({ "unchecked", "rawtypes" }) @Test - void testExplicitGroup() throws Exception { + void explicitGroup() throws Exception { BindingServiceProperties properties = new BindingServiceProperties(); Map bindingProperties = new HashMap<>(); BindingProperties props = new BindingProperties(); @@ -313,7 +313,7 @@ class BindingServiceTests { @Test @Disabled - void testProducerPropertiesValidation() { + void producerPropertiesValidation() { BindingServiceProperties serviceProperties = new BindingServiceProperties(); Map bindingProperties = new HashMap<>(); BindingProperties props = new BindingProperties(); @@ -338,7 +338,7 @@ class BindingServiceTests { } @Test - void testDefaultPropertyBehavior() { + void defaultPropertyBehavior() { ConfigurableApplicationContext run = SpringApplication.run( DefaultConsumerPropertiesTestSink.class, "--server.port=0", @@ -388,7 +388,7 @@ class BindingServiceTests { @Test @Disabled - void testConsumerPropertiesValidation() { + void consumerPropertiesValidation() { BindingServiceProperties serviceProperties = new BindingServiceProperties(); Map bindingProperties = new HashMap<>(); BindingProperties props = new BindingProperties(); @@ -413,7 +413,7 @@ class BindingServiceTests { } @Test - void testUnknownBinderOnBindingFailure() { + void unknownBinderOnBindingFailure() { HashMap properties = new HashMap<>(); properties.put("spring.cloud.stream.bindings.input.destination", "fooInput"); properties.put("spring.cloud.stream.bindings.input.binder", "mock"); @@ -435,7 +435,7 @@ class BindingServiceTests { @SuppressWarnings("unchecked") @Test - void testUnrecognizedBinderAllowedIfNotUsed() { + void unrecognizedBinderAllowedIfNotUsed() { HashMap properties = new HashMap<>(); properties.put("spring.cloud.stream.bindings.input.destination", "fooInput"); properties.put("spring.cloud.stream.bindings.output.destination", "fooOutput"); @@ -455,7 +455,7 @@ class BindingServiceTests { @SuppressWarnings("unchecked") @Test - void testUnrecognizedBinderDisallowedIfUsed() { + void unrecognizedBinderDisallowedIfUsed() { HashMap properties = new HashMap<>(); properties.put("spring.cloud.stream.bindings.input.destination", "fooInput"); properties.put("spring.cloud.stream.bindings.input.binder", "mock1"); @@ -481,7 +481,7 @@ class BindingServiceTests { } @Test - void testResolveBindableType() { + void resolveBindableType() { Class bindableType = GenericsUtils.getParameterType(FooBinder.class, Binder.class, 0); assertThat(bindableType).isSameAs(SomeBindableType.class); @@ -489,7 +489,7 @@ class BindingServiceTests { @SuppressWarnings({ "rawtypes", "unchecked" }) @Test - void testLateBindingProducer() throws Exception { + void lateBindingProducer() throws Exception { BindingServiceProperties properties = new BindingServiceProperties(); properties.setBindingRetryInterval(1); Map bindingProperties = new HashMap<>(); @@ -538,7 +538,7 @@ class BindingServiceTests { @SuppressWarnings("unchecked") @Test - void testBindingAutostartup() throws Exception { + void bindingAutostartup() throws Exception { ApplicationContext context = new SpringApplicationBuilder(FooConfiguration.class) .web(WebApplicationType.NONE).run("--spring.jmx.enabled=false", "--spring.cloud.stream.bindings.input-in-0.consumer.auto-startup=false"); @@ -554,7 +554,7 @@ class BindingServiceTests { @SuppressWarnings("unchecked") @Test - void testBindingNameAsTopLevelProperty() throws Exception { + void bindingNameAsTopLevelProperty() throws Exception { ApplicationContext context = new SpringApplicationBuilder(BarConfiguration.class) .web(WebApplicationType.NONE).run(); diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/ExplicitBindingTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/ExplicitBindingTests.java index 028485700..87c00d1d0 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/ExplicitBindingTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/ExplicitBindingTests.java @@ -37,7 +37,7 @@ import static org.assertj.core.api.Assertions.assertThat; class ExplicitBindingTests { @Test - void testExplicitBindings() { + void explicitBindings() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(EmptyConfiguration.class)) .web(WebApplicationType.NONE) @@ -53,7 +53,7 @@ class ExplicitBindingTests { } @Test - void testExplicitBindingsWithExistingFunctionalBean() { + void explicitBindingsWithExistingFunctionalBean() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ConsumerConfiguration.class)) .web(WebApplicationType.NONE) @@ -75,7 +75,7 @@ class ExplicitBindingTests { } @Test - void testExplicitBindingsWithExistingConsumer() { + void explicitBindingsWithExistingConsumer() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ConsumerConfiguration.class)) .web(WebApplicationType.NONE) @@ -89,7 +89,7 @@ class ExplicitBindingTests { @Disabled @Test - void testExplicitBindingsWithExistingSupplier() { + void explicitBindingsWithExistingSupplier() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SupplierConfiguration.class)) .web(WebApplicationType.NONE) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/FluxMessageChannelBindingTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/FluxMessageChannelBindingTests.java index 00c0875de..5277ab071 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/FluxMessageChannelBindingTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binding/FluxMessageChannelBindingTests.java @@ -39,7 +39,7 @@ import static org.assertj.core.api.Assertions.assertThat; class FluxMessageChannelBindingTests { @Test - void testFluxMessageChannelBindingWhenReactiveOptIn() { + void fluxMessageChannelBindingWhenReactiveOptIn() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ReactiveFunctionConfiguration.class)) .web(WebApplicationType.NONE) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/BindingHandlerAdviseTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/BindingHandlerAdviseTests.java index e8f3fb49f..6616ab054 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/BindingHandlerAdviseTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/BindingHandlerAdviseTests.java @@ -47,14 +47,14 @@ class BindingHandlerAdviseTests { @Test @Disabled - void testFailureWithWrongValue() { + void failureWithWrongValue() { assertThatExceptionOfType(BeanCreationException.class) .isThrownBy(() -> new SpringApplicationBuilder(SampleConfiguration.class).web(WebApplicationType.NONE).run("--props.value=-1", "--spring.jmx.enabled=false")); } @Test - void testValidatedValueValue() { + void validatedValueValue() { ValidatedProps validatedProps = new SpringApplicationBuilder(SampleConfiguration.class) .web(WebApplicationType.NONE).run("--props.value=2", "--spring.jmx.enabled=false") .getBean(ValidatedProps.class); diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/BindingServiceConfigurationTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/BindingServiceConfigurationTests.java index 4452b53db..618f95eb9 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/BindingServiceConfigurationTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/BindingServiceConfigurationTests.java @@ -42,7 +42,7 @@ import static org.assertj.core.api.Assertions.assertThat; class BindingServiceConfigurationTests { @Test - void testErroChannelDistributesMessagesInCaseOfException() { + void erroChannelDistributesMessagesInCaseOfException() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration .getCompleteConfiguration(EmptyConfiguration.class)) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/RetryTemplateTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/RetryTemplateTests.java index 60dc90806..2b40979da 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/RetryTemplateTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/RetryTemplateTests.java @@ -45,7 +45,7 @@ class RetryTemplateTests { @SuppressWarnings("rawtypes") @Test - void testSingleCustomRetryTemplate() throws Exception { + void singleCustomRetryTemplate() throws Exception { ApplicationContext context = new SpringApplicationBuilder( SingleCustomRetryTemplateConfiguration.class).web(WebApplicationType.NONE) .run("--spring.jmx.enabled=false"); @@ -60,7 +60,7 @@ class RetryTemplateTests { @SuppressWarnings("rawtypes") @Test - void testSpecificCustomRetryTemplate() throws Exception { + void specificCustomRetryTemplate() throws Exception { ApplicationContext context = new SpringApplicationBuilder( SpecificCustomRetryTemplateConfiguration.class) .web(WebApplicationType.NONE).run("--spring.jmx.enabled=false", diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/endpoint/ActuatorBindingsTest.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/endpoint/ActuatorBindingsTest.java index b6d0b5cd1..1cd6e43da 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/endpoint/ActuatorBindingsTest.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/endpoint/ActuatorBindingsTest.java @@ -51,7 +51,7 @@ class ActuatorBindingsTest { * it does not result in recursive exception described in https://github.com/spring-cloud/spring-cloud-stream/issues/2253 */ @Test - void test_2253() { + void actuatorDoesNotCauseInfiniteRecursion() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(Bindings.class)) .web(WebApplicationType.NONE).run("--spring.jmx.enabled=false", diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/DynamicDestinationFunctionTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/DynamicDestinationFunctionTests.java index 941a0aa41..f50333f9c 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/DynamicDestinationFunctionTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/DynamicDestinationFunctionTests.java @@ -27,7 +27,6 @@ import org.springframework.cloud.stream.binder.test.OutputDestination; import org.springframework.cloud.stream.binder.test.TestChannelBinderConfiguration; import org.springframework.cloud.stream.config.BindingServiceProperties; import org.springframework.context.annotation.Bean; -import org.springframework.messaging.Message; import org.springframework.messaging.support.GenericMessage; import static org.assertj.core.api.Assertions.assertThat; @@ -50,7 +49,7 @@ class DynamicDestinationFunctionTests { @Test @Disabled - void testEmptyConfiguration() { + void emptyConfiguration() { TestChannelBinderConfiguration.applicationContextRunner(SampleConfiguration.class) .withPropertyValues( "spring.jmx.enabled=false", @@ -72,26 +71,11 @@ class DynamicDestinationFunctionTests { @EnableAutoConfiguration public static class SampleConfiguration { -// @Autowired -// private BinderAwareChannelResolver resolver; - @Bean public PartitionKeyExtractorStrategy keyExtractor() { - return new PartitionKeyExtractorStrategy() { - - @Override - public Object extractKey(Message message) { - return 0; - } - }; + return message -> 0; } -// @Bean -// public Consumer cons() { -// return value -> { -// resolver.resolveDestination(value).send(new GenericMessage(value)); -// }; -// } } } diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java index 975c95a2f..3cd20c3e1 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java @@ -45,7 +45,7 @@ import static org.assertj.core.api.Assertions.assertThat; class FunctionBatchingTests { @Test - void testMessageBatchConfigurationWithKafkaNull() { + void messageBatchConfigurationWithKafkaNull() { TestChannelBinderConfiguration.applicationContextRunner(MessageBatchConfiguration.class) .withPropertyValues("spring.jmx.enabled=false", "spring.cloud.stream.function.definition=func", @@ -75,7 +75,7 @@ class FunctionBatchingTests { } @Test - void testListPayloadConfiguration() { + void listPayloadConfiguration() { TestChannelBinderConfiguration.applicationContextRunner(ListPayloadNotBatchConfiguration.class) .withPropertyValues("spring.jmx.enabled=false", "spring.cloud.stream.function.definition=func") @@ -99,7 +99,7 @@ class FunctionBatchingTests { } @Test - void testListStringPayloadConfigurationTextPlain() { + void listStringPayloadConfigurationTextPlain() { TestChannelBinderConfiguration.applicationContextRunner(ListStringPayloadConfiguration.class) .withPropertyValues("spring.jmx.enabled=false", "spring.cloud.stream.function.definition=func", @@ -120,7 +120,7 @@ class FunctionBatchingTests { } @Test - void testListObjectPayloadObjectConfigurationTextPlain() { + void listObjectPayloadObjectConfigurationTextPlain() { TestChannelBinderConfiguration.applicationContextRunner(ListObjectPayloadConfiguration.class) .withPropertyValues("spring.jmx.enabled=false", "spring.cloud.stream.function.definition=func", @@ -141,7 +141,7 @@ class FunctionBatchingTests { } @Test - void testSimpleBatchConfiguration() { + void simpleBatchConfiguration() { TestChannelBinderConfiguration.applicationContextRunner(SimpleBatchConfiguration.class) .withPropertyValues( "spring.jmx.enabled=false", @@ -169,7 +169,7 @@ class FunctionBatchingTests { } @Test - void testNestedBatchConfiguration() { + void nestedBatchConfiguration() { TestChannelBinderConfiguration.applicationContextRunner(NestedBatchConfiguration.class) .withPropertyValues("spring.jmx.enabled=false", "spring.cloud.stream.function.definition=func", diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/FunctionPostProcessingTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/FunctionPostProcessingTests.java index c41975f12..24bcc3d0b 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/FunctionPostProcessingTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/FunctionPostProcessingTests.java @@ -42,7 +42,7 @@ import static org.assertj.core.api.Assertions.assertThat; class FunctionPostProcessingTests { @Test - void testNothingIsBroken() { + void verifyNothingIsBroken() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(PostProcessingTestConfiguration.class)) @@ -59,7 +59,7 @@ class FunctionPostProcessingTests { } @Test - void testSuccessfulPostProcessingOfSingleFunction() { + void successfulPostProcessingOfSingleFunction() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(PostProcessingTestConfiguration.class)) @@ -77,7 +77,7 @@ class FunctionPostProcessingTests { } @Test - void testNoPostProcessingOnError() { + void noPostProcessingOnError() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(PostProcessingTestConfiguration.class)) @@ -95,7 +95,7 @@ class FunctionPostProcessingTests { } @Test - void testNoFailureOnPostProcessingError() { + void noFailureOnPostProcessingError() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(PostProcessingTestConfiguration.class)) @@ -114,7 +114,7 @@ class FunctionPostProcessingTests { @Test - void testWithCompositionLastFunctionIsPostProcessing() { + void withCompositionLastFunctionIsPostProcessing() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(PostProcessingTestConfiguration.class)) @@ -132,7 +132,7 @@ class FunctionPostProcessingTests { } @Test - void testWithCompositionFirstFunctionIsPostProcessing() { + void withCompositionFirstFunctionIsPostProcessing() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(PostProcessingTestConfiguration.class)) @@ -150,7 +150,7 @@ class FunctionPostProcessingTests { } @Test - void testOlnyLastPostProcessorInvoked() { + void onlyLastPostProcessorInvoked() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(PostProcessingTestConfiguration.class)) @@ -169,7 +169,7 @@ class FunctionPostProcessingTests { } @Test - void testOlnyLastPostProcessorInvoked2() { + void onlyLastPostProcessorInvoked2() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(PostProcessingTestConfiguration.class)) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java index 312a910b0..470291011 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java @@ -48,7 +48,7 @@ import static org.assertj.core.api.Assertions.assertThat; class GreenfieldFunctionEnableBindingTests { @Test - void testProcessorFromFunction() { + void processorFromFunction() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ProcessorFromFunction.class)).web(WebApplicationType.NONE).run( @@ -64,7 +64,7 @@ class GreenfieldFunctionEnableBindingTests { } @Test - void testSinkFromConsumer() { + void sinkFromConsumer() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration .getCompleteConfiguration(SinkFromConsumer.class)) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java index 4ea98c66b..cf254c6c9 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java @@ -97,7 +97,7 @@ class ImplicitFunctionBindingTests { @Test - void testFailedApplicationListenerConfiguration() { + void failedApplicationListenerConfiguration() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(FailedApplicationListenerConfiguration.class)) .web(WebApplicationType.NONE) @@ -114,7 +114,7 @@ class ImplicitFunctionBindingTests { @SuppressWarnings({"rawtypes"}) @Test - void testDisableAutodetect() { + void disableAutodetect() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SendToDestinationConfiguration.class)) .web(WebApplicationType.NONE) @@ -131,7 +131,7 @@ class ImplicitFunctionBindingTests { @SuppressWarnings({"rawtypes" }) @Test - void testBindingControl() { + void bindingControl() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SendToDestinationConfiguration.class)) .web(WebApplicationType.NONE) @@ -147,7 +147,7 @@ class ImplicitFunctionBindingTests { @ParameterizedTest @ValueSource(strings = {"single-destination", "destination1,destination2,destination3"}) - void testGh2658_WithMultipleDestinations(String destination) { + void gh2658_WithMultipleDestinations(String destination) { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleConsumerWithMultipleDestinationConfiguration.class)) .web(WebApplicationType.NONE) @@ -171,7 +171,7 @@ class ImplicitFunctionBindingTests { } @Test - void testGh2658_queryBindingThatNotExists() { + void gh2658_queryBindingThatNotExists() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleConsumerWithMultipleDestinationConfiguration.class)) .web(WebApplicationType.NONE) @@ -241,7 +241,7 @@ class ImplicitFunctionBindingTests { } @Test - void testEmptyConfiguration() { + void emptyConfiguration() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(EmptyConfiguration.class)) @@ -254,7 +254,7 @@ class ImplicitFunctionBindingTests { } @Test - void testNullMessage() { + void nullMessage() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NullMessagerConfiguration.class)) @@ -279,7 +279,7 @@ class ImplicitFunctionBindingTests { } @Test - void testSimpleFunctionWithStreamProperty() { + void simpleFunctionWithStreamProperty() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NoEnableBindingConfiguration.class)) @@ -299,7 +299,7 @@ class ImplicitFunctionBindingTests { } @Test - void testHeaderRetentionWithComposition() { + void headerRetentionWithComposition() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NoEnableBindingConfiguration.class)) @@ -321,7 +321,7 @@ class ImplicitFunctionBindingTests { } @Test - void testReactiveFunctionWithState() { + void reactiveFunctionWithState() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NoEnableBindingConfiguration.class)) @@ -348,7 +348,7 @@ class ImplicitFunctionBindingTests { @SuppressWarnings("rawtypes") @Test - void testFunctionWithUseNativeEncoding() { + void functionWithUseNativeEncoding() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NoEnableBindingConfiguration.class)) @@ -367,7 +367,7 @@ class ImplicitFunctionBindingTests { } @Test - void testSimpleFunctionWithNativeProperty() { + void simpleFunctionWithNativeProperty() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NoEnableBindingConfiguration.class)) @@ -387,7 +387,7 @@ class ImplicitFunctionBindingTests { } @Test - void testSimpleFunctionWithoutDefinitionProperty() { + void simpleFunctionWithoutDefinitionProperty() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleFunctionConfiguration.class)) @@ -406,7 +406,7 @@ class ImplicitFunctionBindingTests { } @Test - void testSimpleConsumerWithoutDefinitionProperty() { + void simpleConsumerWithoutDefinitionProperty() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleConsumerConfiguration.class)) @@ -422,7 +422,7 @@ class ImplicitFunctionBindingTests { } @Test - void fooFunctionComposedWithConsumerNoOutputChannel() { + void functionComposedWithConsumerNoOutputChannel() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ReactiveFunctionConfiguration.class, SingleReactiveConsumerConfiguration.class)) @@ -440,7 +440,7 @@ class ImplicitFunctionBindingTests { } @Test - void fooFunctionComposedWithConsumerNonReactive() { + void functionComposedWithConsumerNonReactive() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(FunctionConsumerCopositionConfiguration.class)) @@ -458,7 +458,7 @@ class ImplicitFunctionBindingTests { } @Test - void testReactiveConsumerWithoutDefinitionProperty() { + void reactiveConsumerWithoutDefinitionProperty() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleReactiveConsumerConfiguration.class)) @@ -474,7 +474,7 @@ class ImplicitFunctionBindingTests { } @Test - void testConsumer() { + void basicConsumer() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleConsumerConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.cloud.function.definition=consumer", @@ -487,7 +487,7 @@ class ImplicitFunctionBindingTests { } @Test - void testBindingWithReactiveFunction() { + void bindingWithReactiveFunction() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ReactiveFunctionConfiguration.class)) @@ -521,7 +521,7 @@ class ImplicitFunctionBindingTests { // } @Test - void testDeclaredTypeVsActualInstance() { + void declaredTypeVsActualInstance() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SCF_GH_409Configuration.class)) @@ -540,7 +540,7 @@ class ImplicitFunctionBindingTests { } @Test - void testWithContextTypeApplicationProperty() { + void withContextTypeApplicationProperty() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleFunctionConfiguration.class)) @@ -563,7 +563,7 @@ class ImplicitFunctionBindingTests { } @Test - void testWithIntegrationFlowAsFunction() { + void withIntegrationFlowAsFunction() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(FunctionSampleSpringIntegrationConfiguration.class)) @@ -583,7 +583,7 @@ class ImplicitFunctionBindingTests { @Test @Disabled - void testSupplierWithCustomPoller() { + void supplierWithCustomPoller() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SupplierWithExplicitPollerConfiguration.class)) @@ -602,7 +602,7 @@ class ImplicitFunctionBindingTests { @Test @Disabled - void testImperativeSupplierReactiveFunctionComposition() { + void imperativeSupplierReactiveFunctionComposition() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ImperativeSupplierComposedWithReactiveFunctionConfiguration.class)) @@ -627,11 +627,9 @@ class ImplicitFunctionBindingTests { } } - - @Test @Disabled - void testSupplierWithCustomPollerAndMappedOutput() { + void supplierWithCustomPollerAndMappedOutput() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SupplierWithExplicitPollerConfiguration.class)) @@ -650,7 +648,7 @@ class ImplicitFunctionBindingTests { } @Test - void testNoFunctionEnabledConfiguration() { + void noFunctionEnabledConfiguration() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(NoFunctionEnabledConfiguration.class)) @@ -680,7 +678,7 @@ class ImplicitFunctionBindingTests { } @Test - void testCollectionAndMapConversionDuringComposition() { + void collectionAndMapConversionDuringComposition() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(CompositionWithCollectionConfiguration.class)) @@ -701,7 +699,7 @@ class ImplicitFunctionBindingTests { // see https://github.com/spring-cloud/spring-cloud-stream/issues/1896 @Test - void testOutputAsCollectionOfMessages() { + void outputAsCollectionOfMessages() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(SplittableTypesConfiguration.class)) @@ -724,7 +722,7 @@ class ImplicitFunctionBindingTests { } @Test - void testOutputAsArrayOfMessages() { + void outputAsArrayOfMessages() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(SplittableTypesConfiguration.class)) @@ -747,7 +745,7 @@ class ImplicitFunctionBindingTests { } @Test - void testWithExplicitBindingInstructions() { + void withExplicitBindingInstructions() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(SplittableTypesConfiguration.class)) @@ -774,7 +772,7 @@ class ImplicitFunctionBindingTests { } @Test - void testWithExplicitBindingInstructionsOnlyDestination() { + void withExplicitBindingInstructionsOnlyDestination() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(SplittableTypesConfiguration.class)) @@ -926,7 +924,7 @@ class ImplicitFunctionBindingTests { } @Test - void testReactiveFunctionWithOutputAsMonoVoid() { + void reactiveFunctionWithOutputAsMonoVoid() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(FunctionalConsumerConfiguration.class)) @@ -943,7 +941,7 @@ class ImplicitFunctionBindingTests { } @Test - void testReactiveSendToDestinationConfiguration() { + void reactiveSendToDestinationConfiguration() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SendToDestinationConfiguration.class)) @@ -969,7 +967,7 @@ class ImplicitFunctionBindingTests { // See this issue for more context on this test: https://github.com/spring-cloud/spring-cloud-stream/issues/2770 @Test - void testSendToDestinationWhenPartitionsEnabled() { + void sendToDestinationWhenPartitionsEnabled() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ImperativeSendToDestinationConfiguration.class)) @@ -1013,7 +1011,7 @@ class ImplicitFunctionBindingTests { @Test @ExtendWith(OutputCaptureExtension.class) - void testReactiveConsumerWithConcurrencyGreaterThanOneLogsWarning(CapturedOutput output) { + void reactiveConsumerWithConcurrencyGreaterThanOneLogsWarning(CapturedOutput output) { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext ignored = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ReactiveConsumerWithConcurrencyFailureConfiguration.class)) @@ -1024,7 +1022,7 @@ class ImplicitFunctionBindingTests { } @Test - void testGh1973() { + void gh1973() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SupplierAndProcessorConfiguration.class)) @@ -1046,7 +1044,7 @@ class ImplicitFunctionBindingTests { } @Test - void testGh1944() { + void gh1944() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SupplierAndPojoConfiguration.class)) @@ -1060,7 +1058,7 @@ class ImplicitFunctionBindingTests { } @Test - void testGh2054() { + void gh2054() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ReactiveFunctionConfiguration.class)) @@ -1080,7 +1078,7 @@ class ImplicitFunctionBindingTests { @Test - void testGh2062() { + void gh2062() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(ReactiveFunctionConfiguration.class)) @@ -1096,7 +1094,7 @@ class ImplicitFunctionBindingTests { @SuppressWarnings("rawtypes") @Test - void testWithNativeEncodingImperative() { + void withNativeEncodingImperative() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleFunctionConfiguration2.class)) @@ -1134,7 +1132,7 @@ class ImplicitFunctionBindingTests { @SuppressWarnings("rawtypes") @Test - void testWithNativeEncodingReactive() { + void withNativeEncodingReactive() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleFunctionConfiguration2.class)) @@ -1200,7 +1198,7 @@ class ImplicitFunctionBindingTests { } @Test - void testHeaderPropagation() { + void headerPropagation() { System.clearProperty("spring.cloud.function.definition"); try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SingleFunctionConfiguration.class)) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/MultipleInputOutputFunctionTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/MultipleInputOutputFunctionTests.java index 584851e35..c71772ed0 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/MultipleInputOutputFunctionTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/MultipleInputOutputFunctionTests.java @@ -55,7 +55,7 @@ import static org.assertj.core.api.Assertions.assertThatExceptionOfType; class MultipleInputOutputFunctionTests { @Test - void testFailureWithNonReactiveFunction() { + void failureWithNonReactiveFunction() { assertThatExceptionOfType(BeanCreationException.class) .isThrownBy(() -> new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( @@ -66,7 +66,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testFailureWithReactiveArrayOutput() { + void failureWithReactiveArrayOutput() { assertThatExceptionOfType(BeanCreationException.class) .isThrownBy(() -> new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( @@ -77,7 +77,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testFailureWithReactiveArrayOutputNonGeneric() { + void failureWithReactiveArrayOutputNonGeneric() { assertThatExceptionOfType(BeanCreationException.class) .isThrownBy(() -> new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( @@ -88,7 +88,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testFailureWithReactiveArrayInput() { + void failureWithReactiveArrayInput() { assertThatExceptionOfType(BeanCreationException.class) .isThrownBy(() -> new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( @@ -99,7 +99,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testFailureWithReactiveArrayInputNonGeneric() { + void failureWithReactiveArrayInputNonGeneric() { assertThatExceptionOfType(BeanCreationException.class) .isThrownBy(() -> new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( @@ -110,7 +110,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testFailureWithConsumer() { + void failureWithConsumer() { assertThatExceptionOfType(BeanCreationException.class) .isThrownBy(() -> new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( @@ -121,7 +121,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testMultiInputSingleOutput() { + void multiInputSingleOutput() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ReactiveFunctionConfiguration.class)) @@ -144,7 +144,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testMultiInputMessageSingleOutput() { + void multiInputMessageSingleOutput() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ReactiveFunctionConfiguration.class)) @@ -167,7 +167,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testSingleInputMultiOutput() { + void singleInputMultiOutput() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ReactiveFunctionConfiguration.class)) @@ -196,7 +196,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testMultipleFunctions() { + void multipleFunctions() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ReactiveFunctionConfiguration.class)) @@ -219,7 +219,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testMultipleFunctionsWithComposition() { + void multipleFunctionsWithComposition() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ReactiveFunctionConfiguration.class)) @@ -243,7 +243,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testMultiInputSingleOutputWithCustomContentType() { + void multiInputSingleOutputWithCustomContentType() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ContentTypeConfiguration.class)) @@ -268,7 +268,7 @@ class MultipleInputOutputFunctionTests { } @Test - void testMultiInputSingleOutputWithCustomContentType2() { + void multiInputSingleOutputWithCustomContentType2() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( ContentTypeConfiguration.class)) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/PollableSourceTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/PollableSourceTests.java index 72f81a4fc..49e84c946 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/PollableSourceTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/PollableSourceTests.java @@ -38,8 +38,6 @@ import org.springframework.scheduling.support.PeriodicTrigger; import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThatExceptionOfType; - - /** * * @author Oleg Zhurakousky @@ -49,7 +47,7 @@ import static org.assertj.core.api.Assertions.assertThatExceptionOfType; class PollableSourceTests { @Test - void testPollableSource() { + void pollableSource() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(PollableAppSampleConfiguration.class)) .web(WebApplicationType.NONE).run( @@ -71,7 +69,7 @@ class PollableSourceTests { } @Test - void testPollerDefaultFixedDelay() { + void pollerDefaultFixedDelay() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(PollableAppSampleConfiguration.class)) .web(WebApplicationType.NONE).run()) { @@ -85,7 +83,7 @@ class PollableSourceTests { } @Test - void testPollerProvidedFixedDelayAndMaxMessagesPerPoll() { + void pollerProvidedFixedDelayAndMaxMessagesPerPoll() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(PollableAppSampleConfiguration.class)) .web(WebApplicationType.NONE).run( @@ -101,7 +99,7 @@ class PollableSourceTests { } @Test - void testNoPollerFixedDelayIfFixedRatePresent() { + void noPollerFixedDelayIfFixedRatePresent() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(PollableAppSampleConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.integration.poller.fixed-rate=200")) { @@ -115,7 +113,7 @@ class PollableSourceTests { } @Test - void testPollerMutualProperties() { + void pollerMutualProperties() { assertThatExceptionOfType(BeanCreationException.class) .isThrownBy(() -> new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(PollableAppSampleConfiguration.class)) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/RoutingFunctionTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/RoutingFunctionTests.java index fded36341..7407a248e 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/RoutingFunctionTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/RoutingFunctionTests.java @@ -62,7 +62,7 @@ class RoutingFunctionTests { } @Test - void testRoutingViaExplicitEnablingAndDefinitionHeader() { + void routingViaExplicitEnablingAndDefinitionHeader() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -87,7 +87,7 @@ class RoutingFunctionTests { } @Test - void testRoutingViaExplicitEnablingAndRoutingExpressionProperty() { + void routingViaExplicitEnablingAndRoutingExpressionProperty() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -112,7 +112,7 @@ class RoutingFunctionTests { } @Test - void testRoutingViaExplicitEnablingAndRoutingExpressionHeader() { + void routingViaExplicitEnablingAndRoutingExpressionHeader() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -137,7 +137,7 @@ class RoutingFunctionTests { } @Test - void testRoutingViaExplicitDefinitionAndDefinitionHeader() { + void routingViaExplicitDefinitionAndDefinitionHeader() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -162,7 +162,7 @@ class RoutingFunctionTests { } @Test - void testDefaultRoutingFunctionBindingFlux() { + void defaultRoutingFunctionBindingFlux() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -188,7 +188,7 @@ class RoutingFunctionTests { @Test - void testPojoFunction() { + void pojoFunction() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -213,7 +213,7 @@ class RoutingFunctionTests { } @Test - void testExplicitRoutingFunctionBindingWithCompositionAndRoutingEnabledExplicitly() { + void explicitRoutingFunctionBindingWithCompositionAndRoutingEnabledExplicitly() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -236,7 +236,7 @@ class RoutingFunctionTests { } @Test - void testExplicitRoutingFunctionBindingWithCompositionAndRoutingEnabledImplicitly() { + void explicitRoutingFunctionBindingWithCompositionAndRoutingEnabledImplicitly() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -258,7 +258,7 @@ class RoutingFunctionTests { } @Test - void testExplicitRoutingFunctionBindingWithCompositionAndRoutingEnabledExplicitlyAndMoreComposition() { + void explicitRoutingFunctionBindingWithCompositionAndRoutingEnabledExplicitlyAndMoreComposition() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -282,7 +282,7 @@ class RoutingFunctionTests { } @Test - void testExplicitRoutingFunctionBindingWithCompositionAndRoutingEnabledImplicitlyAndMoreComposition() { + void explicitRoutingFunctionBindingWithCompositionAndRoutingEnabledImplicitlyAndMoreComposition() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingFunctionConfiguration.class)) @@ -305,7 +305,7 @@ class RoutingFunctionTests { @SuppressWarnings("unchecked") @Test - void testRoutingToConsumers() throws Exception { + void routingToConsumers() throws Exception { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration( RoutingConsumerConfiguration.class)) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ScenarioTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ScenarioTests.java index 1a45c6c1a..504288800 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ScenarioTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ScenarioTests.java @@ -82,7 +82,7 @@ class ScenarioTests { } @Test - void testComposingSupplierWuthTypelessMessageFunction() throws Exception { + void composingSupplierWuthTypelessMessageFunction() throws Exception { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SupplierConfiguration.class)) .web(WebApplicationType.NONE) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java index b0d4acde6..80f5a4ef8 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java @@ -236,7 +236,7 @@ class StreamBridgeTests { * See https://github.com/spring-cloud/spring-cloud-stream/issues/2299 for more details */ @Test - void test_2299_scstPartitionAlwaysSetEvenInConcurrentScenarios() throws Exception { + void scstPartitionAlwaysSetEvenInConcurrentScenarios() throws Exception { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(EmptyConfiguration.class)).web( WebApplicationType.NONE).run("--spring.cloud.stream.source=outputA", @@ -272,7 +272,7 @@ class StreamBridgeTests { } @Test - void testWithOutputContentTypeWildCardBindings() { + void withOutputContentTypeWildCardBindings() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(ConsumerConfiguration.class, EmptyConfigurationWithCustomConverters.class)) .web(WebApplicationType.NONE).run( @@ -294,7 +294,7 @@ class StreamBridgeTests { // See this issue for more details: https://github.com/spring-cloud/spring-cloud-stream/issues/2805 @Test - void testStreamBridgeSendWithBinderNameAndCustomContentType() throws Exception { + void streamBridgeSendWithBinderNameAndCustomContentType() throws Exception { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(ConsumerConfiguration.class, EmptyConfigurationWithCustomConverters.class)) .web(WebApplicationType.NONE).run( @@ -312,7 +312,7 @@ class StreamBridgeTests { @SuppressWarnings("unchecked") @Test - void testNoCachingOfStreamBridgeFunction() throws Exception { + void noCachingOfStreamBridgeFunction() throws Exception { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(ConsumerConfiguration.class, InterceptorConfiguration.class)) .web(WebApplicationType.NONE).run( @@ -331,7 +331,7 @@ class StreamBridgeTests { } @Test - void testDelayedSend() { + void delayedSend() { ScheduledExecutorService executor = Executors.newScheduledThreadPool(1); try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(ConsumerConfiguration.class, EmptyConfiguration.class)) @@ -352,7 +352,7 @@ class StreamBridgeTests { } @Test - void testWithInterceptorsMatchedAgainstAllPatterns() { + void withInterceptorsMatchedAgainstAllPatterns() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(ConsumerConfiguration.class, InterceptorConfiguration.class)) .web(WebApplicationType.NONE).run( @@ -381,7 +381,7 @@ class StreamBridgeTests { } @Test - void testInterceptorIsNotAddedMultipleTimesToTheMessageChannel() { + void interceptorIsNotAddedMultipleTimesToTheMessageChannel() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(InterceptorConfiguration.class)) .web(WebApplicationType.NONE).run( @@ -403,7 +403,7 @@ class StreamBridgeTests { } @Test - void testBindingsAreRemovedWithCache() { + void bindingsAreRemovedWithCache() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(InterceptorConfiguration.class)) .web(WebApplicationType.NONE).run( @@ -424,7 +424,7 @@ class StreamBridgeTests { } @Test - void testWithInterceptorsRegisteredOnlyOnOutputChannel() throws InterruptedException { + void withInterceptorsRegisteredOnlyOnOutputChannel() throws InterruptedException { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(GH2180Configuration.class)) .web(WebApplicationType.NONE).run( @@ -445,7 +445,7 @@ class StreamBridgeTests { } @Test - void testBindingPropertiesAreHonored() { + void bindingPropertiesAreHonored() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(ConsumerConfiguration.class)) .web(WebApplicationType.NONE).run( @@ -471,7 +471,7 @@ class StreamBridgeTests { //see https://github.com/spring-cloud/spring-cloud-function/issues/573 for more details @Test - void testBridgeActivationWhenFunctionDefinitionIsPresent() { + void bridgeActivationWhenFunctionDefinitionIsPresent() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(SimpleConfiguration.class)) .web(WebApplicationType.NONE).run( @@ -487,7 +487,7 @@ class StreamBridgeTests { } @Test - void testNoBridgeIfNoSourcePropertyDefined() { + void noBridgeIfNoSourcePropertyDefined() { assertThatExceptionOfType(NoSuchBeanDefinitionException.class) .isThrownBy(() -> { ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration @@ -498,7 +498,7 @@ class StreamBridgeTests { } @Test - void testBridgeFunctions() { + void bridgeFunctions() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(EmptyConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.cloud.stream.source=foo;bar", @@ -516,7 +516,7 @@ class StreamBridgeTests { } @Test - void testBridgeFunctionsSendingMessagePreservingHeaders() { + void bridgeFunctionsSendingMessagePreservingHeaders() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(EmptyConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.cloud.stream.source=foo;bar", @@ -541,7 +541,7 @@ class StreamBridgeTests { } @Test - void testBridgeFunctionsWitthPartitionInformation() { + void bridgeFunctionsWitthPartitionInformation() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(EmptyConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.cloud.stream.source=foo;bar", @@ -596,7 +596,7 @@ class StreamBridgeTests { } @Test - void testSendingMessageToOutputOfExistingSupplier() { + void sendingMessageToOutputOfExistingSupplier() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(TestConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.cloud.stream.output-bindings=supplier;foo")) { @@ -616,7 +616,7 @@ class StreamBridgeTests { } @Test - void testDynamicDestination() { + void dynamicDestination() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(TestConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.jmx.enabled=false")) { @@ -640,7 +640,7 @@ class StreamBridgeTests { } @Test - void testDynamicDestinationDestroy() { + void dynamicDestinationDestroy() { BindingService bindingService; try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(InterceptorConfiguration.class)) @@ -659,7 +659,7 @@ class StreamBridgeTests { } @Test - void testWithIntegrationFlowBecauseMarcinSaidSo() { + void withIntegrationFlowBecauseMarcinSaidSo() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(IntegrationFlowConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.jmx.enabled=false")) { @@ -674,7 +674,7 @@ class StreamBridgeTests { } @Test - void testNewBindingCallback() { + void newBindingCallback() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration .getCompleteConfiguration(BindingCallbackConfiguration.class)) .web(WebApplicationType.NONE).run("--spring.cloud.stream.source=uppercase", @@ -687,7 +687,7 @@ class StreamBridgeTests { } @Test - void testDynamicProducerDestination() { + void dynamicProducerDestination() { System.clearProperty("spring.cloud.function.definition"); ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(DynamicProducerDestinationConfig.class)) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/edgecases/GH1801Test.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/edgecases/GH1801Test.java index 6d6585cca..d1bdfeb13 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/edgecases/GH1801Test.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/edgecases/GH1801Test.java @@ -37,7 +37,7 @@ import org.springframework.messaging.Message; class GH1801Test { @Test - void test() { + void verifyNoNPEWhenFactoryMethodNull() { SampleBootApplication.main("--spring.cloud.stream.defaultBinder=integration"); } diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/kotlin/KotlinConfigurationTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/kotlin/KotlinConfigurationTests.java index f14cff564..5e398cf61 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/kotlin/KotlinConfigurationTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/kotlin/KotlinConfigurationTests.java @@ -30,7 +30,7 @@ import static org.assertj.core.api.Assertions.assertThat; class KotlinConfigurationTests { @Test - void testKotlinSupplierPollableBean() { + void kotlinSupplierPollableBean() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(KotlinTestConfiguration.class)) .web(WebApplicationType.NONE)