public final class ExchangeBuilder extends AbstractBuilder
Exchange
s.Constructor and Description |
---|
ExchangeBuilder(String name,
String type)
Construct an instance of the appropriate type.
|
Modifier and Type | Method and Description |
---|---|
ExchangeBuilder |
autoDelete()
Set the auto delete flag.
|
Exchange |
build() |
ExchangeBuilder |
delayed()
Set the delayed flag.
|
static ExchangeBuilder |
directExchange(String name)
Return a
DirectExchange builder. |
ExchangeBuilder |
durable()
Deprecated.
- in 2.0, durable will be true by default
|
ExchangeBuilder |
durable(boolean durable)
Set the durable flag.
|
static ExchangeBuilder |
fanoutExchange(String name)
Return a
FanoutExchange builder. |
static ExchangeBuilder |
headersExchange(String name)
Return a
HeadersExchange builder. |
ExchangeBuilder |
internal()
Set the internal flag.
|
static ExchangeBuilder |
topicExchange(String name)
Return a
TopicExchange builder. |
ExchangeBuilder |
withArgument(String key,
Object value)
Add an argument.
|
ExchangeBuilder |
withArguments(Map<String,Object> arguments)
Add the arguments.
|
getArguments, getOrCreateArguments
public ExchangeBuilder(String name, String type)
name
- the exchange nametype
- the type nameExchangeTypes
public static ExchangeBuilder directExchange(String name)
DirectExchange
builder.name
- the name.public static ExchangeBuilder topicExchange(String name)
TopicExchange
builder.name
- the name.public static ExchangeBuilder fanoutExchange(String name)
FanoutExchange
builder.name
- the name.public static ExchangeBuilder headersExchange(String name)
HeadersExchange
builder.name
- the name.public ExchangeBuilder autoDelete()
@Deprecated public ExchangeBuilder durable()
durable(boolean)
public ExchangeBuilder durable(boolean durable)
durable
- the durable flag (default false).durable
public ExchangeBuilder withArgument(String key, Object value)
key
- the argument key.value
- the argument value.public ExchangeBuilder withArguments(Map<String,Object> arguments)
arguments
- the arguments map.public ExchangeBuilder internal()
public ExchangeBuilder delayed()
public Exchange build()