Skip to content

Instantly share code, notes, and snippets.

Avatar
🏠
Working from home

Sergio Sánchez Sánchez sergio11

🏠
Working from home
View GitHub Profile
View tweet_entity.java
@Data
@EqualsAndHashCode(callSuper = false)
@AllArgsConstructor
@NoArgsConstructor
@Document(indexName = "tweets_processed")
public class TweetEntity {
@Id
@Field(type = FieldType.Long)
private Long id;
View tweets_processed_handler.java
@Slf4j
@RequiredArgsConstructor
@Component
public class TweetsProcessedHandler {
private final ITweetsService tweetService;
/**
*
* @param newProcessedTweet
View covid_tweets_ingest.java
@Slf4j
@RequiredArgsConstructor
public class TwitterMessageProducer extends MessageProducerSupport {
private final TwitterStream twitterStream;
private final MessageChannel outputChannel;
private final TweetEntityMapper tweetEntityMapper;
@Getter
@Setter
View covid_tweets_processor.java
@Component
@Slf4j
@RequiredArgsConstructor
public class TweetsIngestHandler {
/**
* Text Analyzer Service
*/
private final ITextAnalyzerService textAnalyzerService;