Support queue options

Author: kevinresol

src/why/pubsub/amqp/Amqp.hx

@@ -21,7 +21,7 @@ class AmqpBase {
 			wrapped = manager.createChannel({
 				setup: channel -> {
 					Promise.inParallel([for(exchange in config.exchanges) Promise.ofJsPromise(channel.assertExchange(exchange.name, exchange.type))])
-						.next(_ -> Promise.inParallel([for(queue in config.queues) Promise.ofJsPromise(channel.assertQueue(queue.name))]))
+						.next(_ -> Promise.inParallel([for(queue in config.queues) Promise.ofJsPromise(channel.assertQueue(queue.name, queue.options))]))
 						.next(_ -> Promise.inParallel([for(queue in config.queues) for(binding in queue.bindings) Promise.ofJsPromise(channel.bindQueue(queue.name, binding.exchange, binding.pattern))]))
 						.noise()
 						.map(o -> {
@@ -49,6 +49,7 @@ typedef ExchangeConfig = {
 }
 typedef QueueConfig = {
 	final name:String;
+	final ?options:amqp.AmqpChannel.AmpqAssertQueueOptions;
 	final bindings:Array<BindingConfig>;
 }
 typedef BindingConfig = {