Package io.datareplication.producer.feed

Interface FeedProducer

public interface FeedProducer

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	FeedProducer.Builder

Method Summary

Modifier and Type	Method	Description
@NonNull java.util.concurrent.CompletionStage<java.lang.Integer>	assignPages()
static @NonNull FeedProducer.Builder	builder(@NonNull FeedEntityRepository feedEntityRepository, @NonNull FeedPageMetadataRepository feedPageMetadataRepository, @NonNull FeedProducerJournalRepository feedProducerJournalRepository)
@NonNull java.util.concurrent.CompletionStage<java.lang.Void>	publish(@NonNull Entity<@NonNull FeedEntityHeader> entity)
@NonNull java.util.concurrent.CompletionStage<java.lang.Void>	publish(@NonNull OperationType operationType, @NonNull Body body)
@NonNull java.util.concurrent.CompletionStage<java.lang.Void>	publish(@NonNull OperationType operationType, @NonNull Body body, @NonNull java.lang.Object userData)

Method Detail

publish

@NonNull
@NonNull java.util.concurrent.CompletionStage<java.lang.Void> publish(@NonNull
                                                                      @NonNull OperationType operationType,
                                                                      @NonNull
                                                                      @NonNull Body body)

publish

@NonNull
@NonNull java.util.concurrent.CompletionStage<java.lang.Void> publish(@NonNull
                                                                      @NonNull OperationType operationType,
                                                                      @NonNull
                                                                      @NonNull Body body,
                                                                      @NonNull
                                                                      @NonNull java.lang.Object userData)

publish

@NonNull
@NonNull java.util.concurrent.CompletionStage<java.lang.Void> publish(@NonNull
                                                                      @NonNull Entity<@NonNull FeedEntityHeader> entity)

assignPages

@NonNull
@NonNull java.util.concurrent.CompletionStage<java.lang.Integer> assignPages()

Returns:

the number of entities added to pages

builder

@NonNull
static @NonNull FeedProducer.Builder builder(@NonNull
                                             @NonNull FeedEntityRepository feedEntityRepository,
                                             @NonNull
                                             @NonNull FeedPageMetadataRepository feedPageMetadataRepository,
                                             @NonNull
                                             @NonNull FeedProducerJournalRepository feedProducerJournalRepository)