AmqpReceiverImpl

Undocumented in source.

class AmqpReceiverImpl : AmqpReceiver {

}

Constructors

this this(string address, AmqpConnectionImpl connection, AmqpReceiverOptions options, ProtonReceiver receiver, Handler!AmqpReceiver completionHandler): Creates a new instance of {@link AmqpReceiverImpl}. This method must be called on the connection context.

address string address(): Undocumented in source. Be warned that the author may not have intended to support it.
close void close(Handler!Void handler): 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.
endHandler AmqpReceiverImpl endHandler(Handler!Void endHandler): Undocumented in source. Be warned that the author may not have intended to support it.
exceptionHandler AmqpReceiver exceptionHandler(Handler!Throwable handler): Undocumented in source. Be warned that the author may not have intended to support it.
fetch AmqpReceiverImpl fetch(long amount): Undocumented in source. Be warned that the author may not have intended to support it.
handler AmqpReceiver handler(Handler!AmqpMessage handler): Undocumented in source. Be warned that the author may not have intended to support it.
pause AmqpReceiverImpl pause(): Undocumented in source. Be warned that the author may not have intended to support it.
resume AmqpReceiverImpl resume(): Undocumented in source. Be warned that the author may not have intended to support it.

exceptionHandler AmqpReceiver exceptionHandler(Handler!Throwable handler): Undocumented in source.
handler AmqpReceiver handler(Handler!AmqpMessage handler): Undocumented in source.
pause AmqpReceiver pause(): Undocumented in source.
resume AmqpReceiver resume(): Undocumented in source.
fetch AmqpReceiver fetch(long amount): Undocumented in source.
endHandler AmqpReceiver endHandler(Handler!Void endHandler): Undocumented in source.
address string address(): The listened address.
close void close(Handler!Void handler): Closes the receiver.
connection AmqpConnection connection(): Gets the connection having created the receiver. Cannot be {@code null}