AmqpSenderImpl

class AmqpSenderImpl : AmqpSender {

}

Constructors

this this(ProtonSender sender, AmqpConnectionImpl connection, Handler!AmqpSender completionHandler): Undocumented in source.

Members

Functions

address string address(): Undocumented in source. Be warned that the author may not have intended to support it.
close void close(VoidAsyncHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
close Future!Void close(): Undocumented in source. Be warned that the author may not have intended to support it.
connection AmqpConnection connection(): Undocumented in source. Be warned that the author may not have intended to support it.
drainHandler AmqpSender drainHandler(Handler!Void handler): Undocumented in source. Be warned that the author may not have intended to support it.
end void end(VoidAsyncHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
exceptionHandler AmqpSender exceptionHandler(Handler!Throwable handler): Undocumented in source. Be warned that the author may not have intended to support it.
send AmqpSender send(AmqpMessage message): Undocumented in source. Be warned that the author may not have intended to support it.
sendWithAck AmqpSender sendWithAck(AmqpMessage message, VoidAsyncHandler acknowledgementHandler): Undocumented in source. Be warned that the author may not have intended to support it.
setWriteQueueMaxSize AmqpSender setWriteQueueMaxSize(int maxSize): Undocumented in source. Be warned that the author may not have intended to support it.
write Future!Void write(AmqpMessage data): Undocumented in source. Be warned that the author may not have intended to support it.
write void write(AmqpMessage data, VoidAsyncHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
writeQueueFull bool writeQueueFull(): Undocumented in source. Be warned that the author may not have intended to support it.

Static functions

create void create(ProtonSender sender, AmqpConnectionImpl connection, Handler!AmqpSender completionHandler): Creates a new instance of {@link AmqpSenderImpl}. The created sender is passed into the {@code completionHandler} once opened. This method must be called on the connection context.

Inherited Members

From AmqpSender

exceptionHandler AmqpSender exceptionHandler(Handler!Throwable handler): Undocumented in source.
setWriteQueueMaxSize AmqpSender setWriteQueueMaxSize(int maxSize): 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.
close void close(VoidAsyncHandler handler): Closes the sender.
close Future!Void close(): Like {@link #close(Handler)} but returns a {@code Future} of the asynchronous result
address string address(): @return the configured address.
connection AmqpConnection connection(): Gets the connection having created the sender. Cannot be {@code null}

AmqpSenderImpl

Constructors

Members

Functions

Static functions

Inherited Members

From AmqpSender

Meta

Source