Package org.apache.pekko.cluster.pubsub

Interface PerGroupingBuffer

All Known Implementing Classes:

DistributedPubSubMediator, DistributedPubSubMediator.Internal$.Topic

public interface PerGroupingBuffer

Method Summary

Modifier and Type	Method	Description
void	bufferOr(java.lang.String grouping, java.lang.Object message, ActorRef originalSender, scala.Function0<scala.runtime.BoxedUnit> action)
void	forwardMessages(java.lang.String grouping, ActorRef recipient)
void	forwardMessages(MessageBuffer messages, ActorRef recipient)
void	initializeGrouping(java.lang.String grouping)
void	recreateAndForwardMessagesIfNeeded(java.lang.String grouping, scala.Function0<ActorRef> recipient)

Method Detail

bufferOr

void bufferOr(java.lang.String grouping,
              java.lang.Object message,
              ActorRef originalSender,
              scala.Function0<scala.runtime.BoxedUnit> action)

forwardMessages

void forwardMessages(java.lang.String grouping,
                     ActorRef recipient)

forwardMessages

void forwardMessages(MessageBuffer messages,
                     ActorRef recipient)

initializeGrouping

void initializeGrouping(java.lang.String grouping)

recreateAndForwardMessagesIfNeeded

void recreateAndForwardMessagesIfNeeded(java.lang.String grouping,
                                        scala.Function0<ActorRef> recipient)