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

Cleaning up tests

Browse Source 
- Remove unused components from CustomPartitionedProducerTest
This commit is contained in:
Soby Chacko
2023-06-02 12:39:14 -04:00
parent 4f6361c6c4
commit 9a773c8647
1 changed files with 2 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2017-2022 the original author or authors.
* Copyright 2017-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.
@@ -39,6 +39,7 @@ import static org.assertj.core.api.Assertions.assertThat;
/**
* @author Ilayaperumal Gopinathan
* @author Oleg Zhurakousky
* @author Soby Chacko
*/
public class CustomPartitionedProducerTest {
@@ -196,20 +197,8 @@ public class CustomPartitionedProducerTest {
return new CustomPartitionKeyExtractorClass();
}
// @Bean
// @InboundChannelAdapter(value = "output", poller = @Poller(fixedDelay = "5000", maxMessagesPerPoll = "1"))
// public MessageSource<String> timerMessageSource() {
// return new MessageSource<String>() {
// @Override
// public Message<String> receive() {
// throw new MessagingException("test");
// }
// };
// }
}
@EnableAutoConfiguration
@PropertySource("classpath:/org/springframework/cloud/stream/binder/custom-partitioned-producer-test.properties")
public static class TestSourceMultipleStrategies {
@@ -234,17 +223,5 @@ public class CustomPartitionedProducerTest {
return new CustomPartitionKeyExtractorClass();
}
// @Bean
// @InboundChannelAdapter(value = "output", poller = @Poller(fixedDelay = "5000", maxMessagesPerPoll = "1"))
// public MessageSource<String> timerMessageSource() {
// return new MessageSource<String>() {
// @Override
// public Message<String> receive() {
// throw new MessagingException("test");
// }
// };
// }
}
}