vertx / io.vertx.reactivex.amqpbridge / AmqpBridge / createConsumer

createConsumer

open fun <T : Any> createConsumer(amqpAddress: String): MessageConsumer<T>

Creates a consumer on the given AMQP address. This method MUST be called from the bridge Context thread, as used in the result handler callback from the start methods. The bridge MUST be successfully started before the method is called.

Parameters

amqpAddress - the address to consume from

Return
the consumer