AmqpReceiver

Interface used to consume AMQP message as a stream of message. Back pressure is implemented using AMQP credits.

interface AmqpReceiver : ReadStream!AmqpMessage {

AmqpReceiver exceptionHandler(Handler!Throwable handler);

AmqpReceiver handler(Handler!AmqpMessage handler);

AmqpReceiver pause();

AmqpReceiver resume();

AmqpReceiver fetch(long amount);

AmqpReceiver endHandler(Handler!Void endHandler);

string address();

void close(Handler!Void handler);

AmqpConnection connection();

}

Members

Functions

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}
endHandler AmqpReceiver endHandler(Handler!Void endHandler): Undocumented in source.
exceptionHandler AmqpReceiver exceptionHandler(Handler!Throwable handler): Undocumented in source.
fetch AmqpReceiver fetch(long amount): Undocumented in source.
handler AmqpReceiver handler(Handler!AmqpMessage handler): Undocumented in source.
pause AmqpReceiver pause(): Undocumented in source.
resume AmqpReceiver resume(): Undocumented in source.

Meta

Source

See Implementation

hunt amqp client AmqpReceiver interfaces

AmqpReceiver