AmqpSender

AMQP Sender interface used to send messages.

interface AmqpSender : WriteStream!AmqpMessage {

AmqpSender exceptionHandler(Handler!Throwable handler);

AmqpSender setWriteQueueMaxSize(int maxSize);

AmqpSender send(AmqpMessage message);

AmqpSender sendWithAck(AmqpMessage message, VoidAsyncHandler acknowledgementHandler);

void close(VoidAsyncHandler handler);

Future!Void close();

string address();

AmqpConnection connection();

}

Members

Functions

address string address(): @return the configured address.
close Future!Void close(): Like {@link #close(Handler)} but returns a {@code Future} of the asynchronous result
close void close(VoidAsyncHandler handler): Closes the sender.
connection AmqpConnection connection(): Gets the connection having created the sender. Cannot be {@code null}
exceptionHandler AmqpSender exceptionHandler(Handler!Throwable handler): Undocumented in source.
send AmqpSender send(AmqpMessage message): Sends an AMQP message. The destination the configured sender address or the address configured in the message.
sendWithAck AmqpSender sendWithAck(AmqpMessage message, VoidAsyncHandler acknowledgementHandler): Sends an AMQP message and waits for an acknowledgement. The acknowledgement handler is called with an {@link AsyncResult} marked as failed if the message has been rejected or re-routed. If the message has been accepted, the handler is called with a success.
setWriteQueueMaxSize AmqpSender setWriteQueueMaxSize(int maxSize): Undocumented in source.

Meta

Source

See Implementation

hunt amqp client AmqpSender interfaces

AmqpSender