akka.persistence
Class ChannelSettings

java.lang.Object
  extended by akka.persistence.ChannelSettings
All Implemented Interfaces:
java.io.Serializable, scala.Equals, scala.Product

public class ChannelSettings
extends java.lang.Object
implements scala.Product, scala.Serializable

A Channel configuration object.

param: redeliverMax Maximum number of redelivery attempts. param: redeliverInterval Interval between redelivery attempts. param: redeliverFailureListener Receiver of RedeliverFailure notifications which are sent when the number of redeliveries reaches redeliverMax for a sequence of messages. To enforce a redelivery of these messages, the listener has to restart the sending processor. Alternatively, it can also confirm these messages, preventing further redeliveries.

See Also:
Serialized Form

Constructor Summary
ChannelSettings(int redeliverMax, scala.concurrent.duration.FiniteDuration redeliverInterval, scala.Option<ActorRef> redeliverFailureListener)
           
 
Method Summary
static ChannelSettings create()
          Java API.
 scala.Option<ActorRef> redeliverFailureListener()
           
 scala.concurrent.duration.FiniteDuration redeliverInterval()
           
 int redeliverMax()
           
 ChannelSettings withRedeliverFailureListener(ActorRef redeliverFailureListener)
          Java API.
 ChannelSettings withRedeliverInterval(scala.concurrent.duration.FiniteDuration redeliverInterval)
          Java API.
 ChannelSettings withRedeliverMax(int redeliverMax)
          Java 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

ChannelSettings

public ChannelSettings(int redeliverMax,
                       scala.concurrent.duration.FiniteDuration redeliverInterval,
                       scala.Option<ActorRef> redeliverFailureListener)
Method Detail

create

public static ChannelSettings create()
Java API.

Returns:
(undocumented)

redeliverMax

public int redeliverMax()

redeliverInterval

public scala.concurrent.duration.FiniteDuration redeliverInterval()

redeliverFailureListener

public scala.Option<ActorRef> redeliverFailureListener()

withRedeliverMax

public ChannelSettings withRedeliverMax(int redeliverMax)
Java API.

Parameters:
redeliverMax - (undocumented)
Returns:
(undocumented)

withRedeliverInterval

public ChannelSettings withRedeliverInterval(scala.concurrent.duration.FiniteDuration redeliverInterval)
Java API.

Parameters:
redeliverInterval - (undocumented)
Returns:
(undocumented)

withRedeliverFailureListener

public ChannelSettings withRedeliverFailureListener(ActorRef redeliverFailureListener)
Java API.

Parameters:
redeliverFailureListener - (undocumented)
Returns:
(undocumented)