public interface AmqpSender extends io.vertx.core.streams.WriteStream<AmqpMessage>
Modifier and Type | Method and Description |
---|---|
String |
address() |
io.vertx.core.Future<Void> |
close()
Like
close(Handler) but returns a Future of the asynchronous result |
void |
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
Closes the sender.
|
AmqpConnection |
connection()
Gets the connection having created the sender.
|
AmqpSender |
exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
long |
remainingCredits() |
AmqpSender |
send(AmqpMessage message)
Sends an AMQP message.
|
io.vertx.core.Future<Void> |
sendWithAck(AmqpMessage message)
Like
sendWithAck(AmqpMessage, Handler) but returns a Future of the asynchronous result |
AmqpSender |
sendWithAck(AmqpMessage message,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> acknowledgementHandler)
Sends an AMQP message and waits for an acknowledgement.
|
AmqpSender |
setWriteQueueMaxSize(int maxSize) |
AmqpSender exceptionHandler(io.vertx.core.Handler<Throwable> handler)
exceptionHandler
in interface io.vertx.core.streams.StreamBase
exceptionHandler
in interface io.vertx.core.streams.WriteStream<AmqpMessage>
AmqpSender setWriteQueueMaxSize(int maxSize)
setWriteQueueMaxSize
in interface io.vertx.core.streams.WriteStream<AmqpMessage>
AmqpSender send(AmqpMessage message)
message
- the message, must not be null
AmqpSender sendWithAck(AmqpMessage message, io.vertx.core.Handler<io.vertx.core.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
io.vertx.core.Future<Void> sendWithAck(AmqpMessage message)
sendWithAck(AmqpMessage, Handler)
but returns a Future
of the asynchronous resultvoid close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
handler
- called when the sender has been closed, must not be null
io.vertx.core.Future<Void> close()
close(Handler)
but returns a Future
of the asynchronous resultString address()
AmqpConnection connection()
null
long remainingCredits()
Copyright © 2022 Eclipse. All rights reserved.