Package org.springframework.cloud.fn.supplier.twitter.message

Class TwitterMessageSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.twitter.message.TwitterMessageSupplierConfiguration

@EnableConfigurationProperties(TwitterMessageSupplierProperties.class)
@Import(TwitterConnectionConfiguration.class)
public class TwitterMessageSupplierConfiguration
extends Object

Author:

Christian Tzolov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TwitterMessageSupplierConfiguration.MessageCursor

Constructor Summary

Constructors

Constructor	Description
TwitterMessageSupplierConfiguration()

Method Summary

Modifier and Type	Method	Description
TwitterMessageSupplierConfiguration.MessageCursor	cursor()
Supplier<List<twitter4j.DirectMessage>>	directMessagesSupplier(TwitterMessageSupplierProperties properties, twitter4j.Twitter twitter, TwitterMessageSupplierConfiguration.MessageCursor cursorState)
Function<List<twitter4j.DirectMessage>,List<twitter4j.DirectMessage>>	messageDeduplicate(org.springframework.integration.metadata.MetadataStore metadataStore)
org.springframework.integration.metadata.MetadataStore	metadataStore()
Supplier<Message<byte[]>>	twitterMessageSupplier(Function<List<twitter4j.DirectMessage>,List<twitter4j.DirectMessage>> messageDeduplicate, Function<Object,Message<byte[]>> managedJson, Supplier<List<twitter4j.DirectMessage>> directMessagesSupplier)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TwitterMessageSupplierConfiguration

public TwitterMessageSupplierConfiguration()

Method Details

metadataStore

@Bean
@ConditionalOnMissingBean
public org.springframework.integration.metadata.MetadataStore metadataStore()

cursor

@Bean
@ConditionalOnMissingBean
public TwitterMessageSupplierConfiguration.MessageCursor cursor()

directMessagesSupplier

@Bean
public Supplier<List<twitter4j.DirectMessage>> directMessagesSupplier(TwitterMessageSupplierProperties properties,
 twitter4j.Twitter twitter,
 TwitterMessageSupplierConfiguration.MessageCursor cursorState)

messageDeduplicate

@Bean
public Function<List<twitter4j.DirectMessage>,List<twitter4j.DirectMessage>> messageDeduplicate(org.springframework.integration.metadata.MetadataStore metadataStore)

twitterMessageSupplier

@Bean
public Supplier<Message<byte[]>> twitterMessageSupplier(Function<List<twitter4j.DirectMessage>,List<twitter4j.DirectMessage>> messageDeduplicate,
 Function<Object,Message<byte[]>> managedJson,
 Supplier<List<twitter4j.DirectMessage>> directMessagesSupplier)