public interface AmqpSender extends WriteStream<AmqpMessage>
Modifier and Type | Method and Description |
---|---|
String |
address() |
void |
close(Handler<AsyncResult<Void>> handler)
Closes the sender.
|
AmqpConnection |
connection()
Gets the connection having created the sender.
|
AmqpSender |
send(AmqpMessage message)
Sends an AMQP message.
|
AmqpSender |
sendWithAck(AmqpMessage message,
Handler<AsyncResult<Void>> acknowledgementHandler)
Sends an AMQP message and waits for an acknowledgement.
|
drainHandler, end, end, exceptionHandler, setWriteQueueMaxSize, write, writeQueueFull
AmqpSender send(AmqpMessage message)
message
- the message, must not be null
AmqpSender sendWithAck(AmqpMessage message, Handler<AsyncResult<Void>> acknowledgementHandler)
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.message
- the message, must not be null
acknowledgementHandler
- the acknowledgement handler, must not be null
void close(Handler<AsyncResult<Void>> handler)
handler
- called when the sender has been closed, must not be null
String address()
AmqpConnection connection()
null
Copyright © 2019 Eclipse. All rights reserved.