diff --git a/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java b/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java
index f8fe3a9dc..8db7c861f 100644
--- a/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java
+++ b/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java
@@ -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");
-//				}
-//			};
-//		}
-
 	}
-
 }