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<AmqpAnnotatedMessage> send(AmqpAnnotatedMessage message)

Sends a message to the management node.

abstract Mono<AmqpAnnotatedMessage> send(AmqpAnnotatedMessage message, DeliveryOutcome deliveryOutcome)

Sends a message to the management node and associates the deliveryOutcome with that message.

Method Details

send

public abstract Mono send(AmqpAnnotatedMessage message)

Sends a message to the management node.

Parameters:

message - Message to send.

Returns:

Response from management node.

send

public abstract Mono 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.

Applies to