Package org.acemq.amqp.transport

Class OutboundMessage.Builder

java.lang.Object

org.acemq.amqp.transport.OutboundMessage.Builder

Enclosing class:

OutboundMessage

public static final class OutboundMessage.Builder
extends Object

Builds OutboundMessage instances.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
OutboundMessage.Builder	allowUnroutable()	Allows the broker to drop the message when nothing is bound to receive it.
OutboundMessage.Builder	alwaysConfirmed()	Confirms this publish and checks it for a return even on a connection made without publisher confirms.
OutboundMessage.Builder	body(byte[] body)
OutboundMessage	build()
OutboundMessage.Builder	contentType(@Nullable String contentType)
OutboundMessage.Builder	exchange(String exchange)
OutboundMessage.Builder	expiration(@Nullable Duration expiration)	Asks the broker to discard the message if it is still undelivered after this long.
OutboundMessage.Builder	header(String name, Object value)
OutboundMessage.Builder	headers(Map<String,Object> headers)
OutboundMessage.Builder	messageId(@Nullable String messageId)
OutboundMessage.Builder	priority(@Nullable Integer priority)	Sets the priority this message is published with.
OutboundMessage.Builder	replyTo(@Nullable String replyTo)	Names the queue a reply should be sent to.
OutboundMessage.Builder	routingKey(String routingKey)
OutboundMessage.Builder	transientDelivery()	Marks the message transient, so a broker restart may lose it.

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

exchange

public OutboundMessage.Builder exchange(String exchange)

routingKey

public OutboundMessage.Builder routingKey(String routingKey)

body

public OutboundMessage.Builder body(byte[] body)

header

public OutboundMessage.Builder header(String name,
 Object value)

headers

public OutboundMessage.Builder headers(Map<String,Object> headers)

messageId

public OutboundMessage.Builder messageId(@Nullable String messageId)

contentType

public OutboundMessage.Builder contentType(@Nullable String contentType)

transientDelivery

public OutboundMessage.Builder transientDelivery()

Marks the message transient, so a broker restart may lose it.

allowUnroutable

public OutboundMessage.Builder allowUnroutable()

Allows the broker to drop the message when nothing is bound to receive it.

expiration

public OutboundMessage.Builder expiration(@Nullable Duration expiration)

Asks the broker to discard the message if it is still undelivered after this long.

Parameters:

expiration - positive time-to-live, or null for none

priority

public OutboundMessage.Builder priority(@Nullable Integer priority)

Sets the priority this message is published with.

Only meaningful on a queue declared with a maximum priority; elsewhere the broker ignores it. Higher is more urgent.

Parameters:

priority - priority to publish with, or null for none

Returns:

this builder

replyTo

public OutboundMessage.Builder replyTo(@Nullable String replyTo)

Names the queue a reply should be sent to.

Carried as AMQP's own reply-to property rather than an AceMQ header, so a service written against this library can answer a caller that was not.

Parameters:

replyTo - queue to reply to, or null for a message expecting no reply

Returns:

this builder

alwaysConfirmed

public OutboundMessage.Builder alwaysConfirmed()

Confirms this publish and checks it for a return even on a connection made without publisher confirms.

Returns:

this builder

See Also:

• OutboundMessage.alwaysConfirmed()

build

public OutboundMessage build()