akka.persistence
Class ConfirmablePersistent

java.lang.Object
  akka.persistence.Persistent
      akka.persistence.ConfirmablePersistent

All Implemented Interfaces:

Resequenceable

Direct Known Subclasses:

ConfirmablePersistentImpl

public abstract class ConfirmablePersistent
extends Persistent

Persistent message that has been delivered by a Channel or PersistentChannel. Channel destinations that receive messages of this type can confirm their receipt by calling confirm.

Constructor Summary

ConfirmablePersistent()

Method Summary

abstract void	confirm() Called by Channel and PersistentChannel destinations to confirm the receipt of a persistent message.
abstract int	redeliveries() Number of redeliveries.
static scala.Option<scala.Tuple3<java.lang.Object,java.lang.Object,java.lang.Object>>	unapply(ConfirmablePersistent persistent) ConfirmablePersistent extractor.

Methods inherited from class akka.persistence.Persistent

apply, create, create, payload, sequenceNr, unapply, withPayload

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.persistence.Resequenceable

sender

Constructor Detail

ConfirmablePersistent

public ConfirmablePersistent()

Method Detail

unapply

public static scala.Option<scala.Tuple3<java.lang.Object,java.lang.Object,java.lang.Object>> unapply(ConfirmablePersistent persistent)

ConfirmablePersistent extractor.

Parameters:

persistent - (undocumented)

Returns:

(undocumented)

confirm

public abstract void confirm()

Called by Channel and PersistentChannel destinations to confirm the receipt of a persistent message.

redeliveries

public abstract int redeliveries()

Number of redeliveries. Only greater than zero if message has been redelivered by a Channel or PersistentChannel.

Returns:

(undocumented)