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