AmqpManagementNode Interface
Implements
public interface AmqpManagementNode
extends AsyncCloseable
An AMQP endpoint that allows users to perform management and metadata operations on it.
Method Summary
| Modifier and Type | Method and Description |
|---|---|
|
abstract
Mono<Amqp |
send(AmqpAnnotatedMessage message)
Sends a message to the management node. |
|
abstract
Mono<Amqp |
send(AmqpAnnotatedMessage message, DeliveryOutcome deliveryOutcome)
Sends a message to the management node and associates the |
Method Details
send
public abstract Mono<AmqpAnnotatedMessage> send(AmqpAnnotatedMessage message)
Sends a message to the management node.
Parameters:
message
- Message to send.
Returns:
Response from management node.
send
public abstract Mono<AmqpAnnotatedMessage> send(AmqpAnnotatedMessage message, DeliveryOutcome deliveryOutcome)
Sends a message to the management node and associates the deliveryOutcome with that message.
Parameters:
message
- Message to send.
deliveryOutcome
- Delivery outcome to associate with the message.
Returns:
Response from management node.
