open fun rxQueueDeclare(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean): Single<JsonObject>
Declare a queue
Return
open fun rxQueueDeclare(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: JsonObject): Single<JsonObject>
Declare a queue with config options
Return