io.atomix.group.messaging

Class MessageProducer.Options

java.lang.Object

io.atomix.group.messaging.MessageProducer.Options

Enclosing interface:

MessageProducer<T>

public static class MessageProducer.Options
extends Object

Message producer options.

Producer options allow users to define how messages are delivered to consumers and the criteria by which the cluster determines when the delivery of a message is complete.

Constructor Summary

Constructors

Constructor and Description
Options()

Method Summary

Modifier and Type	Method and Description
MessageProducer.Delivery	getDelivery() Returns the producer delivery policy.
MessageProducer.Execution	getExecution() Returns the producer execution policy.
MessageProducer.Options	withDelivery(MessageProducer.Delivery delivery) Sets the producer delivery policy.
MessageProducer.Options	withExecution(MessageProducer.Execution execution) Sets the producer execution policy.

Methods inherited from class java.lang.Object

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

Constructor Detail

Options

public Options()

Method Detail

withDelivery

public MessageProducer.Options withDelivery(MessageProducer.Delivery delivery)

Sets the producer delivery policy.

Parameters:

delivery - The producer delivery policy.

Returns:

The producer options.

getDelivery

public MessageProducer.Delivery getDelivery()

Returns the producer delivery policy.

Returns:

The producer delivery policy.

withExecution

public MessageProducer.Options withExecution(MessageProducer.Execution execution)

Sets the producer execution policy.

Parameters:

execution - The producer execution policy.

Returns:

The producer options.

getExecution

public MessageProducer.Execution getExecution()

Returns the producer execution policy.

Returns:

The producer execution policy.