@EnableConfigurationProperties(value={TwitterStreamSupplierProperties.class,TwitterConnectionProperties.class}) @Import(value=TwitterConnectionConfiguration.class) public class TwitterStreamSupplierConfiguration extends Object
Constructor and Description |
---|
TwitterStreamSupplierConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.channel.FluxMessageChannel |
output() |
twitter4j.StatusListener |
twitterStatusListener(org.springframework.integration.channel.FluxMessageChannel output,
twitter4j.TwitterStream twitterStream,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> |
twitterStreamSupplier(twitter4j.TwitterStream twitterStream,
org.springframework.integration.channel.FluxMessageChannel output,
TwitterStreamSupplierProperties streamProperties) |
@Bean public org.springframework.integration.channel.FluxMessageChannel output()
@Bean public twitter4j.StatusListener twitterStatusListener(org.springframework.integration.channel.FluxMessageChannel output, twitter4j.TwitterStream twitterStream, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
@Bean public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> twitterStreamSupplier(twitter4j.TwitterStream twitterStream, org.springframework.integration.channel.FluxMessageChannel output, TwitterStreamSupplierProperties streamProperties)
Copyright © 2020. All rights reserved.