PerGroupingBuffer

All Known Implementing Classes:: DistributedPubSubMediator, DistributedPubSubMediator.Internal$.Topic

public interface PerGroupingBuffer

Method Summary

Modifier and Type

Method

Description

void

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

void

forwardMessages(String grouping, ActorRef recipient)

void

forwardMessages(MessageBuffer messages, ActorRef recipient)

void

initializeGrouping(String grouping)

void

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

Method Details
- bufferOr
  
  void bufferOr(String grouping, Object message, ActorRef originalSender, scala.Function0<scala.runtime.BoxedUnit> action)
- forwardMessages
  
  void forwardMessages(String grouping, ActorRef recipient)
- forwardMessages
  
  void forwardMessages(MessageBuffer messages, ActorRef recipient)
- initializeGrouping
  
  void initializeGrouping(String grouping)
- recreateAndForwardMessagesIfNeeded
  
  void recreateAndForwardMessagesIfNeeded(String grouping, scala.Function0<ActorRef> recipient)