timeout for receiving a reply from the destination.
Must be less than policy.confirmationTimeout
redelivery policy for the reliable channel.
Creates a org.eligosource.eventsourced.core.ReliableChannel and a proxy for destination
with the settings defined by this configuration object.
Creates a org.eligosource.eventsourced.core.ReliableChannel and a proxy for destination
with the settings defined by this configuration object. The destination proxy together with
the reliable channel mediate reliable request-reply interactions between a request sender
(usually an Eventsourced
processor) and the destination
.
journal that is used by the channel.
org.eligosource.eventsourced.core.Channel ref factory.
a channel ref.
Channel destination.
Channel destination.
Optional dispatcher name.
Optional dispatcher name.
Channel id.
Channel id.
Optional channel name.
Optional channel name.
redelivery policy for the reliable channel.
timeout for receiving a reply from the destination.
timeout for receiving a reply from the destination.
Must be less than policy.confirmationTimeout
Returns a new ReliableRequestReplyChannelProps
with the specified confirmation timeout.
Returns a new ReliableRequestReplyChannelProps
with the specified dispatcher name.
Returns a new ReliableRequestReplyChannelProps
with the specified name.
Returns a new ReliableRequestReplyChannelProps
with the specified re-delivery delay.
Returns a new ReliableRequestReplyChannelProps
with the specified maximum number of re-delivery attempts.
Returns a new ReliableRequestReplyChannelProps
with the specified reply timeout.
Returns a new ReliableRequestReplyChannelProps
with the specified restart delay.
Returns a new ReliableRequestReplyChannelProps
with the specified maximum number of restarts.
Reliable request-reply channel configuration object used to configure a org.eligosource.eventsourced.core.ReliableChannel and a proxy for
destination
. The destination proxy together with the reliable channel mediate reliable request-reply interactions between a request sender (usually anEventsourced
processor) and thedestination
. The channel created bycreateChannel
has the following properties in addition to a plain reliable channel:destination
.destination
into aMessage
before sending them back to the request sender.replyTimeout
.destination
responds withakka.actor.Status.Failure
.destination
.timeout for receiving a reply from the destination. Must be less than
policy.confirmationTimeout
redelivery policy for the reliable channel.
org.eligosource.eventsourced.core.ReliableChannel.