SpringCloud/spring-functions-catalog
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-115: Fix TwitterUpdateConsumerConfiguration for auto-wire ambiguity

Browse Source 
Fixes: https://github.com/spring-cloud/spring-functions-catalog/issues/115
This commit is contained in:
Artem Bilan
2024-12-19 12:33:01 -05:00
parent 03067496dc
commit 1c351c8c45
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
consumer/spring-twitter-consumer/src/main/java/org/springframework/cloud/fn/consumer/twitter/status/update/TwitterUpdateConsumerConfiguration.java
View File

@@ -27,6 +27,7 @@ import twitter4j.StatusUpdate;
import twitter4j.Twitter; import twitter4j.Twitter;
import twitter4j.TwitterException; import twitter4j.TwitterException;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.AutoConfiguration; import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.cloud.fn.common.twitter.TwitterConnectionConfiguration; import org.springframework.cloud.fn.common.twitter.TwitterConnectionConfiguration;
@@ -37,6 +38,7 @@ import org.springframework.messaging.Message;
* The auto-configuration for Twitter messages. * The auto-configuration for Twitter messages.
* *
* @author Christian Tzolov * @author Christian Tzolov
* @author Artem Bilan
*/ */
@AutoConfiguration(after = TwitterConnectionConfiguration.class) @AutoConfiguration(after = TwitterConnectionConfiguration.class)
@EnableConfigurationProperties(TwitterUpdateConsumerProperties.class) @EnableConfigurationProperties(TwitterUpdateConsumerProperties.class)
@@ -104,8 +106,9 @@ public class TwitterUpdateConsumerConfiguration {
} }
@Bean @Bean
public Consumer<Message<?>> twitterStatusUpdateConsumer(Function<Message<?>, StatusUpdate> statusUpdateQuery, public Consumer<Message<?>> twitterStatusUpdateConsumer(
Consumer<StatusUpdate> updateStatus) { @Qualifier("messageToStatusUpdateFunction") Function<Message<?>, StatusUpdate> statusUpdateQuery,
@Qualifier("twitterUpdateStatusConsumer") Consumer<StatusUpdate> updateStatus) {
return (message) -> updateStatus.accept(statusUpdateQuery.apply(message)); return (message) -> updateStatus.accept(statusUpdateQuery.apply(message));
} }