akka.persistence
Class DeliveredByPersistentChannelBatching

java.lang.Object
  extended by akka.persistence.DeliveredByPersistentChannelBatching
All Implemented Interfaces:
Actor

public class DeliveredByPersistentChannelBatching
extends java.lang.Object
implements Actor

INTERNAL API.


Nested Class Summary
 
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$
 
Constructor Summary
DeliveredByPersistentChannelBatching(ActorRef journal, PersistenceSettings settings)
           
 
Method Summary
 void addToBatch(DeliveredByPersistentChannel pc)
           
 void journalBatch()
           
 boolean maxBatchSizeReached()
           
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
          This defines the initial actor behavior, it must return a partial function with the actor logic.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
 

Constructor Detail

DeliveredByPersistentChannelBatching

public DeliveredByPersistentChannelBatching(ActorRef journal,
                                            PersistenceSettings settings)
Method Detail

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface: Actor
This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:
receive in interface Actor
Returns:
(undocumented)

addToBatch

public void addToBatch(DeliveredByPersistentChannel pc)

maxBatchSizeReached

public boolean maxBatchSizeReached()

journalBatch

public void journalBatch()