akka.persistence
Class ChannelSettings

java.lang.Object
  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)