diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/BatchCapableRejectAndDontRequeueRecovererTest.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/BatchCapableRejectAndDontRequeueRecovererTest.java index 0e700063d..06b56677a 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/BatchCapableRejectAndDontRequeueRecovererTest.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/BatchCapableRejectAndDontRequeueRecovererTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2022-2022 the original author or authors. + * Copyright 2022-2023 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -31,7 +31,7 @@ import static org.assertj.core.api.Assertions.assertThat; class BatchCapableRejectAndDontRequeueRecovererTest { @Test - void testBatchRecoverThrowExceptionCorrectly() { + void batchRecoverThrowExceptionCorrectly() { MessageBatchRecoverer messageBatchRecoverer = new BatchCapableRejectAndDontRequeueRecoverer(); Message expectedMessage1 = new Message(new byte[] {}); @@ -51,7 +51,7 @@ class BatchCapableRejectAndDontRequeueRecovererTest { } @Test - void testRecoverThrowExceptionCorrectly() { + void recoverThrowExceptionCorrectly() { MessageBatchRecoverer messageBatchRecoverer = new BatchCapableRejectAndDontRequeueRecoverer(); Message expectedMessage = new Message(new byte[] {}); diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java index 730b094bc..04973ad1c 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java @@ -75,7 +75,7 @@ class RabbitBinderCleanerTests { RABBITMQ.getHttpPort()); @Test - public void testCleanStream() { + void cleanStream() { final RabbitBindingCleaner cleaner = new RabbitBindingCleaner(); final String stream1 = new Base64UrlNamingStrategy("foo").generateName(); String stream2 = stream1 + "-1"; diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java index d38c37b40..6e83628b4 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java @@ -219,7 +219,7 @@ class RabbitBinderTests extends } @Test - public void testSendAndReceiveBad(TestInfo testInfo) throws Exception { + void sendAndReceiveBad(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); final AtomicReference event = new AtomicReference<>(); binder.getApplicationContext().addApplicationListener( @@ -268,7 +268,7 @@ class RabbitBinderTests extends } @Test - public void testProducerErrorChannel(TestInfo testInfo) throws Exception { + void producerErrorChannel(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); CachingConnectionFactory ccf = this.rabbitTestSupport.getResource(); ccf.setPublisherReturns(true); @@ -353,7 +353,7 @@ class RabbitBinderTests extends } @Test - public void testProducerAckChannel(TestInfo testInfo) throws Exception { + void producerAckChannel(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); CachingConnectionFactory ccf = this.rabbitTestSupport.getResource(); ccf.setPublisherReturns(true); @@ -384,7 +384,7 @@ class RabbitBinderTests extends } @Test - public void testProducerConfirmHeader(TestInfo testInfo) throws Exception { + void producerConfirmHeader(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); CachingConnectionFactory ccf = this.rabbitTestSupport.getResource(); ccf.setPublisherReturns(true); @@ -439,7 +439,7 @@ class RabbitBinderTests extends } @Test - public void testConsumerProperties() throws Exception { + void consumerProperties() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties properties = createConsumerProperties(); properties.getExtension().setRequeueRejected(true); @@ -521,7 +521,7 @@ class RabbitBinderTests extends } @Test - public void testMultiplexOnPartitionedConsumer() throws Exception { + void multiplexOnPartitionedConsumer() throws Exception { final ExtendedConsumerProperties consumerProperties = createConsumerProperties(); RabbitTestSupport.RabbitProxy proxy = new RabbitTestSupport.RabbitProxy(); CachingConnectionFactory cf = new CachingConnectionFactory("localhost", @@ -541,7 +541,7 @@ class RabbitBinderTests extends } @Test - public void testMultiplexOnPartitionedConsumerWithMultipleDestinations() throws Exception { + void multiplexOnPartitionedConsumerWithMultipleDestinations() throws Exception { final ExtendedConsumerProperties consumerProperties = createConsumerProperties(); RabbitTestSupport.RabbitProxy proxy = new RabbitTestSupport.RabbitProxy(); CachingConnectionFactory cf = new CachingConnectionFactory("localhost", @@ -561,7 +561,7 @@ class RabbitBinderTests extends } @Test - public void testConsumerPropertiesWithUserInfrastructureNoBind() throws Exception { + void consumerPropertiesWithUserInfrastructureNoBind() throws Exception { RabbitAdmin admin = new RabbitAdmin(this.rabbitTestSupport.getResource()); Queue queue = new Queue("propsUser1.infra"); admin.declareQueue(queue); @@ -590,7 +590,7 @@ class RabbitBinderTests extends } @Test - public void testAnonWithBuiltInExchange() throws Exception { + void anonWithBuiltInExchange() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties properties = createConsumerProperties(); properties.getExtension().setDeclareExchange(false); @@ -612,7 +612,7 @@ class RabbitBinderTests extends @Test - public void testAnonWithBuiltInExchangeCustomPrefix() throws Exception { + void anonWithBuiltInExchangeCustomPrefix() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties properties = createConsumerProperties(); properties.getExtension().setDeclareExchange(false); @@ -635,7 +635,7 @@ class RabbitBinderTests extends @Test - public void testConsumerPropertiesWithUserInfrastructureCustomExchangeAndRK() + void consumerPropertiesWithUserInfrastructureCustomExchangeAndRK() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties properties = createConsumerProperties(); @@ -692,7 +692,7 @@ class RabbitBinderTests extends } @Test - public void testConsumerPropertiesWithUserInfrastructureCustomQueueArgs() + void consumerPropertiesWithUserInfrastructureCustomQueueArgs() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties properties = createConsumerProperties(); @@ -822,7 +822,7 @@ class RabbitBinderTests extends @SuppressWarnings("unchecked") @Test - public void testConsumerPropertiesWithHeaderExchanges() throws Exception { + void consumerPropertiesWithHeaderExchanges() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties properties = createConsumerProperties(); properties.getExtension().setExchangeType(ExchangeTypes.HEADERS); @@ -876,7 +876,7 @@ class RabbitBinderTests extends @Test - public void testProducerProperties(TestInfo testInfo) throws Exception { + void producerProperties(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); Binding producerBinding = binder.bindProducer("props.0", createBindableChannel("input", new BindingProperties()), @@ -954,7 +954,7 @@ class RabbitBinderTests extends @Test - public void testDurablePubSubWithAutoBindDLQ() throws Exception { + void durablePubSubWithAutoBindDLQ() throws Exception { RabbitAdmin admin = new RabbitAdmin(this.rabbitTestSupport.getResource()); RabbitTestBinder binder = getBinder(); @@ -1003,7 +1003,7 @@ class RabbitBinderTests extends @Test - public void testNonDurablePubSubWithAutoBindDLQ() throws Exception { + void nonDurablePubSubWithAutoBindDLQ() throws Exception { RabbitAdmin admin = new RabbitAdmin(this.rabbitTestSupport.getResource()); RabbitTestBinder binder = getBinder(); @@ -1037,7 +1037,7 @@ class RabbitBinderTests extends @Test - public void testAutoBindDLQ() throws Exception { + void autoBindDLQ() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties consumerProperties = createConsumerProperties(); consumerProperties.getExtension().setPrefix(TEST_PREFIX); @@ -1112,7 +1112,7 @@ class RabbitBinderTests extends @Test - public void testAutoBindDLQManualAcks() throws Exception { + void autoBindDLQManualAcks() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties consumerProperties = createConsumerProperties(); consumerProperties.getExtension().setPrefix(TEST_PREFIX); @@ -1195,7 +1195,7 @@ class RabbitBinderTests extends @Test - public void testAutoBindDLQPartionedConsumerFirst(TestInfo testInfo) throws Exception { + void autoBindDLQPartionedConsumerFirst(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties properties = createConsumerProperties(); properties.getExtension().setPrefix("bindertest."); @@ -1301,13 +1301,13 @@ class RabbitBinderTests extends @Test @Disabled - public void testAutoBindDLQPartitionedConsumerFirstWithRepublishNoRetry(TestInfo testInfo) + void autoBindDLQPartitionedConsumerFirstWithRepublishNoRetry(TestInfo testInfo) throws Exception { testAutoBindDLQPartionedConsumerFirstWithRepublishGuts(false, testInfo); } @Test - public void testAutoBindDLQPartitionedConsumerFirstWithRepublishWithRetry(TestInfo testInfo) + void autoBindDLQPartitionedConsumerFirstWithRepublishWithRetry(TestInfo testInfo) throws Exception { testAutoBindDLQPartionedConsumerFirstWithRepublishGuts(true, testInfo); } @@ -1459,7 +1459,7 @@ class RabbitBinderTests extends } @Test - public void testAutoBindDLQPartitionedProducerFirst(TestInfo testInfo) throws Exception { + void autoBindDLQPartitionedProducerFirst(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties properties = createProducerProperties(testInfo); @@ -1566,7 +1566,7 @@ class RabbitBinderTests extends @Test - public void testAutoBindDLQwithRepublish() throws Exception { + void autoBindDLQwithRepublish() throws Exception { this.maxStackTraceSize = RabbitUtils .getMaxFrame(rabbitTestSupport.getResource()) - 20_000; assertThat(this.maxStackTraceSize).isGreaterThan(0); @@ -1638,7 +1638,7 @@ class RabbitBinderTests extends @SuppressWarnings("unchecked") @Test - public void testAutoBindDLQwithRepublishTx() throws Exception { + void autoBindDLQwithRepublishTx() throws Exception { RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties consumerProperties = createConsumerProperties(); consumerProperties.getExtension().setPrefix(TEST_PREFIX); @@ -1687,7 +1687,7 @@ class RabbitBinderTests extends @SuppressWarnings("unchecked") @Test - public void testAutoBindDLQwithRepublishSimpleConfirms() throws Exception { + void autoBindDLQwithRepublishSimpleConfirms() throws Exception { CachingConnectionFactory ccf = this.rabbitTestSupport.getResource(); ccf.setPublisherReturns(true); ccf.setPublisherConfirmType(ConfirmType.SIMPLE); @@ -1738,7 +1738,7 @@ class RabbitBinderTests extends @SuppressWarnings("unchecked") @Test - public void testAutoBindDLQwithRepublishCorrelatedConfirms() throws Exception { + void autoBindDLQwithRepublishCorrelatedConfirms() throws Exception { CachingConnectionFactory ccf = this.rabbitTestSupport.getResource(); ccf.setPublisherReturns(true); ccf.setPublisherConfirmType(ConfirmType.CORRELATED); @@ -1789,7 +1789,7 @@ class RabbitBinderTests extends @SuppressWarnings("unchecked") @Test - public void testBatchingAndCompression(TestInfo testInfo) throws Exception { + void batchingAndCompression(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); producerProperties.getExtension() @@ -1854,7 +1854,7 @@ class RabbitBinderTests extends @SuppressWarnings("unchecked") @Test - public void testProducerBatching(TestInfo testInfo) throws Exception { + void producerBatching(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); producerProperties.getExtension() @@ -1899,7 +1899,7 @@ class RabbitBinderTests extends @SuppressWarnings("unchecked") @Test - public void testConsumerBatching(TestInfo testInfo) throws Exception { + void consumerBatching(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); producerProperties.getExtension() @@ -1938,7 +1938,7 @@ class RabbitBinderTests extends } @Test - public void testErrorMessageHandlerForBatchModeDLQRepublish(TestInfo testInfo) throws Exception { + void errorMessageHandlerForBatchModeDLQRepublish(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); producerProperties.getExtension() @@ -1991,7 +1991,7 @@ class RabbitBinderTests extends @SuppressWarnings("unchecked") @Test - public void testInternalHeadersNotPropagated(TestInfo testInfo) throws Exception { + void internalHeadersNotPropagated(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); producerProperties.getExtension() @@ -2036,7 +2036,7 @@ class RabbitBinderTests extends * queues. */ @Test - public void testLateBinding(TestInfo testInfo) throws Exception { + void lateBinding(TestInfo testInfo) throws Exception { RabbitTestSupport.RabbitProxy proxy = new RabbitTestSupport.RabbitProxy(); CachingConnectionFactory cf = new CachingConnectionFactory("localhost", proxy.getPort()); @@ -2173,7 +2173,7 @@ class RabbitBinderTests extends @Test - public void testBadUserDeclarationsFatal() throws Exception { + void badUserDeclarationsFatal() throws Exception { RabbitTestBinder binder = getBinder(); ConfigurableApplicationContext context = binder.getApplicationContext(); ConfigurableListableBeanFactory bf = context.getBeanFactory(); @@ -2215,7 +2215,7 @@ class RabbitBinderTests extends @Test - public void testRoutingKeyExpression(TestInfo testInfo) throws Exception { + void routingKeyExpression(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); producerProperties.getExtension().setRoutingKeyExpression( @@ -2261,7 +2261,7 @@ class RabbitBinderTests extends @Test - public void testRoutingKey(TestInfo testInfo) throws Exception { + void routingKey(TestInfo testInfo) throws Exception { String routingKey = "static.key"; RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); @@ -2296,7 +2296,7 @@ class RabbitBinderTests extends @Test - public void testRoutingKeyExpressionPartitionedAndDelay(TestInfo testInfo) throws Exception { + void routingKeyExpressionPartitionedAndDelay(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); producerProperties.getExtension().setRoutingKeyExpression( @@ -2350,7 +2350,7 @@ class RabbitBinderTests extends @Test - public void testPolledConsumer() throws Exception { + void polledConsumer() throws Exception { RabbitTestBinder binder = getBinder(); PollableSource inboundBindTarget = new DefaultPollableMessageSource( this.messageConverter); @@ -2376,7 +2376,7 @@ class RabbitBinderTests extends @Test - public void testPolledConsumerRequeue() throws Exception { + void polledConsumerRequeue() throws Exception { RabbitTestBinder binder = getBinder(); PollableSource inboundBindTarget = new DefaultPollableMessageSource( this.messageConverter); @@ -2410,7 +2410,7 @@ class RabbitBinderTests extends @Test - public void testPolledConsumerWithDlq() throws Exception { + void polledConsumerWithDlq() throws Exception { RabbitTestBinder binder = getBinder(); PollableSource inboundBindTarget = new DefaultPollableMessageSource( this.messageConverter); @@ -2447,7 +2447,7 @@ class RabbitBinderTests extends @Test - public void testPolledConsumerWithDlqNoRetry() throws Exception { + void polledConsumerWithDlqNoRetry() throws Exception { RabbitTestBinder binder = getBinder(); PollableSource inboundBindTarget = new DefaultPollableMessageSource( this.messageConverter); @@ -2482,7 +2482,7 @@ class RabbitBinderTests extends @Test - public void testPolledConsumerWithDlqRePub() throws Exception { + void polledConsumerWithDlqRePub() throws Exception { RabbitTestBinder binder = getBinder(); PollableSource inboundBindTarget = new DefaultPollableMessageSource( this.messageConverter); @@ -2514,7 +2514,7 @@ class RabbitBinderTests extends } @Test - public void testCustomBatchingStrategy(TestInfo testInfo) throws Exception { + void customBatchingStrategy(TestInfo testInfo) throws Exception { RabbitTestBinder binder = getBinder(); ExtendedProducerProperties producerProperties = createProducerProperties(testInfo); producerProperties.getExtension().setDeliveryMode(MessageDeliveryMode.NON_PERSISTENT); diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RepublishUnitTests.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RepublishUnitTests.java index 32ff1ebcc..581aace7f 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RepublishUnitTests.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RepublishUnitTests.java @@ -50,7 +50,7 @@ import static org.mockito.Mockito.verify; class RepublishUnitTests { @Test - public void testBadRepublishSetting() throws IOException { + void badRepublishSetting() throws IOException { ConnectionFactory cf = mock(ConnectionFactory.class); Connection conn = mock(Connection.class); given(cf.createConnection()).willReturn(conn); diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java index a72981691..90bc01924 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java @@ -136,7 +136,7 @@ class RabbitBinderModuleTests { } @Test - public void testParentConnectionFactoryInheritedByDefault() throws Exception { + void parentConnectionFactoryInheritedByDefault() throws Exception { context = new SpringApplicationBuilder(SimpleProcessor.class) .web(WebApplicationType.NONE).run("--server.port=0", "--spring.rabbitmq.port=" + RABBITMQ.getAmqpPort(), @@ -208,7 +208,7 @@ class RabbitBinderModuleTests { @Test @SuppressWarnings("unchecked") - public void testParentConnectionFactoryInheritedByDefaultAndRabbitSettingsPropagated() { + void parentConnectionFactoryInheritedByDefaultAndRabbitSettingsPropagated() { context = new SpringApplicationBuilder(SimpleProcessor.class) .web(WebApplicationType.NONE).run("--server.port=0", "--spring.rabbitmq.port=" + RABBITMQ.getAmqpPort(), @@ -271,7 +271,7 @@ class RabbitBinderModuleTests { } @Test - public void testParentConnectionFactoryInheritedIfOverridden() { + void parentConnectionFactoryInheritedIfOverridden() { context = new SpringApplicationBuilder(SimpleProcessor.class, ConnectionFactoryConfiguration.class).web(WebApplicationType.NONE) .run("--server.port=0", "--spring.rabbitmq.port=" + RABBITMQ.getAmqpPort()); @@ -295,7 +295,7 @@ class RabbitBinderModuleTests { } @Test - public void testParentConnectionFactoryNotInheritedByCustomizedBindersAndProducerRetryBootProperties() { + void parentConnectionFactoryNotInheritedByCustomizedBindersAndProducerRetryBootProperties() { List params = new ArrayList<>(); params.add("--spring.cloud.function.definition=process"); params.add("--spring.cloud.stream.process-in-0.binder=custom"); @@ -351,7 +351,7 @@ class RabbitBinderModuleTests { } @Test - public void testCloudProfile() { + void cloudProfile() { this.context = new SpringApplicationBuilder(SimpleProcessor.class, MockCloudConfiguration.class).web(WebApplicationType.NONE) .profiles("cloud").run(); @@ -377,7 +377,7 @@ class RabbitBinderModuleTests { } @Test - public void testExtendedProperties() { + void extendedProperties() { context = new SpringApplicationBuilder(SimpleProcessor.class) .web(WebApplicationType.NONE).run("--server.port=0", "--spring.rabbitmq.port=" + RABBITMQ.getAmqpPort(), diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/stream/RabbitStreamBinderModuleTests.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/stream/RabbitStreamBinderModuleTests.java index 9c12aecea..4dd8bba82 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/stream/RabbitStreamBinderModuleTests.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/stream/RabbitStreamBinderModuleTests.java @@ -65,7 +65,7 @@ class RabbitStreamBinderModuleTests { private static final RabbitMQContainer RABBITMQ = RabbitTestContainer.sharedInstance(); @Test - void testStreamContainer() { + void streamContainer() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(SimpleProcessor.class) .web(WebApplicationType.NONE) .run("--server.port=0")) { @@ -87,7 +87,7 @@ class RabbitStreamBinderModuleTests { } @Test - void testSuperStreamContainer() { + void superStreamContainer() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(SimpleProcessor.class) .web(WebApplicationType.NONE) .run("--server.port=0")) { @@ -114,7 +114,7 @@ class RabbitStreamBinderModuleTests { } @Test - void testStreamHandler() { + void streamHandler() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(SimpleProcessor.class) .web(WebApplicationType.NONE) .run("--server.port=0")) { diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/stream2/RabbitStreamBinderModuleIntegrationTests.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/stream2/RabbitStreamBinderModuleIntegrationTests.java index eb49f1b06..3736cdbbb 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/stream2/RabbitStreamBinderModuleIntegrationTests.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/stream2/RabbitStreamBinderModuleIntegrationTests.java @@ -58,7 +58,7 @@ class RabbitStreamBinderModuleIntegrationTests { private static final RabbitMQContainer RABBITMQ = RabbitTestContainer.sharedInstance(); @Test - void testSuperStreamContainer() throws InterruptedException { + void superStreamContainer() throws InterruptedException { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(SimpleProcessor.class) .web(WebApplicationType.NONE) .run("--server.port=0")) {