Skip to content

Commit 0106acf

Browse files
committed
Expose @KafkaListener BPP method handler factory
Allow external use of the framework's configured factory.
1 parent 7acf1b9 commit 0106acf

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -195,6 +195,15 @@ public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHa
195195
this.messageHandlerMethodFactory.setHandlerMethodFactory(messageHandlerMethodFactory);
196196
}
197197

198+
/**
199+
* Return the configured handler factory.
200+
* @return the factory.
201+
* @since 2.5.7
202+
*/
203+
public MessageHandlerMethodFactory getMessageHandlerMethodFactory() {
204+
return this.messageHandlerMethodFactory;
205+
}
206+
198207
/**
199208
* Making a {@link BeanFactory} available is optional; if not set,
200209
* {@link KafkaListenerConfigurer} beans won't get autodetected and an

0 commit comments

Comments
 (0)