public interface AmqpSender extends io.vertx.core.streams.WriteStream<AmqpMessage>
Modifier and Type | Method and Description |
---|---|
String |
address() |
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) |
AmqpSender |
send(AmqpMessage message)
Sends an AMQP message.
|
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 |
write(AmqpMessage data) |
AmqpSender |
write(AmqpMessage data,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler) |
AmqpSender write(AmqpMessage data)
write
in interface io.vertx.core.streams.WriteStream<AmqpMessage>
AmqpSender write(AmqpMessage data, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
write
in interface io.vertx.core.streams.WriteStream<AmqpMessage>
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
void close(io.vertx.core.Handler<io.vertx.core.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.