SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-2275 Fix checkstyle violations

Browse Source 
Resolves #2275
This commit is contained in:
Oleg Zhurakousky
2022-02-16 10:22:52 +01:00
parent b50480c2ee
commit cf998826b8
1 changed files with 11 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java
View File

@@ -63,8 +63,6 @@ import org.springframework.util.MimeTypeUtils;
import org.springframework.util.ReflectionUtils;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
/**
@@ -73,7 +71,6 @@ import static org.junit.Assert.fail;
* @author Soby Chacko
*
*/
@SuppressWarnings("deprecation")
public class StreamBridgeTests {
@Before
@@ -471,14 +468,6 @@ public class StreamBridgeTests {
assertThat(context.getBean("callbackVerifier", AtomicBoolean.class)).isTrue();
}
}
@EnableAutoConfiguration
public static class DynamicProducerDestinationConfig {
@Bean
public Function<Message<String>, Message<String>> uppercase() {
return msg -> MessageBuilder.withPayload(msg.getPayload().toUpperCase())
.setHeader("spring.cloud.stream.sendto.destination", "dynamicTopic").build();
}
}
@Test
public void testDynamicProducerDestination() {
@@ -497,8 +486,17 @@ public class StreamBridgeTests {
OutputDestination target = context.getBean(OutputDestination.class);
Message<byte[]> message = target.receive(5, "dynamicTopic");
assertNotNull(message);
assertEquals("JOHN DOE", new String(message.getPayload()));
assertThat(message).isNotNull();
assertThat(new String(message.getPayload())).isEqualTo("JOHN DOE");
}
@EnableAutoConfiguration
public static class DynamicProducerDestinationConfig {
@Bean
public Function<Message<String>, Message<String>> uppercase() {
return msg -> MessageBuilder.withPayload(msg.getPayload().toUpperCase())
.setHeader("spring.cloud.stream.sendto.destination", "dynamicTopic").build();
}
}
@EnableAutoConfiguration