@Configuration @EnableConfigurationProperties(value=TwitterFriendshipsSupplierProperties.class) @Import(value=TwitterConnectionConfiguration.class) public class TwitterFriendshipsSupplierConfiguration extends Object
Constructor and Description |
---|
TwitterFriendshipsSupplierConfiguration() |
Modifier and Type | Method and Description |
---|---|
Cursor |
cursor() |
Supplier<org.springframework.messaging.Message<byte[]>> |
deduplicatedFriendsJsonSupplier(Function<List<twitter4j.User>,List<twitter4j.User>> userDeduplication,
Supplier<List<twitter4j.User>> userRetriever,
Function<Object,org.springframework.messaging.Message<byte[]>> managedJson) |
Supplier<List<twitter4j.User>> |
followersSupplier(TwitterFriendshipsSupplierProperties properties,
twitter4j.Twitter twitter,
Cursor cursorState) |
Supplier<List<twitter4j.User>> |
friendsSupplier(TwitterFriendshipsSupplierProperties properties,
twitter4j.Twitter twitter,
Cursor cursorState) |
org.springframework.integration.metadata.MetadataStore |
metadataStore() |
Function<List<twitter4j.User>,List<twitter4j.User>> |
userDeduplicate(org.springframework.integration.metadata.MetadataStore metadataStore) |
public TwitterFriendshipsSupplierConfiguration()
@Bean @ConditionalOnMissingBean public org.springframework.integration.metadata.MetadataStore metadataStore()
@Bean @ConditionalOnMissingBean public Cursor cursor()
@Bean @ConditionalOnProperty(name="twitter.friendships.source.type", havingValue="followers") public Supplier<List<twitter4j.User>> followersSupplier(TwitterFriendshipsSupplierProperties properties, twitter4j.Twitter twitter, Cursor cursorState)
@Bean @ConditionalOnProperty(name="twitter.friendships.source.type", havingValue="friends") public Supplier<List<twitter4j.User>> friendsSupplier(TwitterFriendshipsSupplierProperties properties, twitter4j.Twitter twitter, Cursor cursorState)
@Bean public Function<List<twitter4j.User>,List<twitter4j.User>> userDeduplicate(org.springframework.integration.metadata.MetadataStore metadataStore)
@Bean public Supplier<org.springframework.messaging.Message<byte[]>> deduplicatedFriendsJsonSupplier(Function<List<twitter4j.User>,List<twitter4j.User>> userDeduplication, Supplier<List<twitter4j.User>> userRetriever, Function<Object,org.springframework.messaging.Message<byte[]>> managedJson)
Copyright © 2020. All rights reserved.