From 1c351c8c4555370ab961c427d4aa44bfa0033fd4 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 19 Dec 2024 12:33:01 -0500 Subject: [PATCH] GH-115: Fix `TwitterUpdateConsumerConfiguration` for auto-wire ambiguity Fixes: https://github.com/spring-cloud/spring-functions-catalog/issues/115 --- .../status/update/TwitterUpdateConsumerConfiguration.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/consumer/spring-twitter-consumer/src/main/java/org/springframework/cloud/fn/consumer/twitter/status/update/TwitterUpdateConsumerConfiguration.java b/consumer/spring-twitter-consumer/src/main/java/org/springframework/cloud/fn/consumer/twitter/status/update/TwitterUpdateConsumerConfiguration.java index bafebe61..ca39537b 100644 --- a/consumer/spring-twitter-consumer/src/main/java/org/springframework/cloud/fn/consumer/twitter/status/update/TwitterUpdateConsumerConfiguration.java +++ b/consumer/spring-twitter-consumer/src/main/java/org/springframework/cloud/fn/consumer/twitter/status/update/TwitterUpdateConsumerConfiguration.java @@ -27,6 +27,7 @@ import twitter4j.StatusUpdate; import twitter4j.Twitter; import twitter4j.TwitterException; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.autoconfigure.AutoConfiguration; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.cloud.fn.common.twitter.TwitterConnectionConfiguration; @@ -37,6 +38,7 @@ import org.springframework.messaging.Message; * The auto-configuration for Twitter messages. * * @author Christian Tzolov + * @author Artem Bilan */ @AutoConfiguration(after = TwitterConnectionConfiguration.class) @EnableConfigurationProperties(TwitterUpdateConsumerProperties.class) @@ -104,8 +106,9 @@ public class TwitterUpdateConsumerConfiguration { } @Bean - public Consumer> twitterStatusUpdateConsumer(Function, StatusUpdate> statusUpdateQuery, - Consumer updateStatus) { + public Consumer> twitterStatusUpdateConsumer( + @Qualifier("messageToStatusUpdateFunction") Function, StatusUpdate> statusUpdateQuery, + @Qualifier("twitterUpdateStatusConsumer") Consumer updateStatus) { return (message) -> updateStatus.accept(statusUpdateQuery.apply(message)); }