akka.persistence
Class DeliveredByPersistentChannel

java.lang.Object
  extended by akka.persistence.DeliveredByPersistentChannel
All Implemented Interfaces:
Delivered, PersistentId, Message, java.io.Serializable, scala.Equals, scala.Product

public class DeliveredByPersistentChannel
extends java.lang.Object
implements Delivered, PersistentId, scala.Product, scala.Serializable

Plugin API.

See Also:
Serialized Form

Constructor Summary
DeliveredByPersistentChannel(java.lang.String channelId, long persistentSequenceNr, long deliverySequenceNr, ActorRef channel)
           
 
Method Summary
 ActorRef channel()
           
 java.lang.String channelId()
           
 long deliverySequenceNr()
           
 long persistentSequenceNr()
           
 java.lang.String processorId()
          Id of processor that journals a persistent message
 long sequenceNr()
          A persistent message's sequence number.
 DeliveredByPersistentChannel update(long deliverySequenceNr, ActorRef channel)
          INTERNAL API.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface scala.Product
productArity, productElement, productIterator, productPrefix
 
Methods inherited from interface scala.Equals
canEqual, equals
 

Constructor Detail

DeliveredByPersistentChannel

public DeliveredByPersistentChannel(java.lang.String channelId,
                                    long persistentSequenceNr,
                                    long deliverySequenceNr,
                                    ActorRef channel)
Method Detail

channelId

public java.lang.String channelId()
Specified by:
channelId in interface Delivered

persistentSequenceNr

public long persistentSequenceNr()
Specified by:
persistentSequenceNr in interface Delivered

deliverySequenceNr

public long deliverySequenceNr()
Specified by:
deliverySequenceNr in interface Delivered

channel

public ActorRef channel()
Specified by:
channel in interface Delivered

processorId

public java.lang.String processorId()
Description copied from interface: PersistentId
Id of processor that journals a persistent message

Specified by:
processorId in interface PersistentId

sequenceNr

public long sequenceNr()
Description copied from interface: PersistentId
A persistent message's sequence number.

Specified by:
sequenceNr in interface PersistentId

update

public DeliveredByPersistentChannel update(long deliverySequenceNr,
                                           ActorRef channel)
Description copied from interface: Delivered
INTERNAL API.

Specified by:
update in interface Delivered