     client.subscribeToQueue queue, ackHandler, cb
 
   async.map handlers, sub, callback
-
+# End utils
+
+
+# Tests
 transportTests = (type) ->
   address = transports[type]
   broker = null

        chai.expect(msg).to.include.keys 'data'
        chai.expect(msg.data).to.eql payload
        done()
      connectAll [sender, receiver], (err) ->
        receiver.createQueue 'inqueue', inQueue, (err) ->
          chai.expect(err).to.be.a 'null'
          sender.createQueue 'outqueue', outQueue, (err) ->
            chai.expect(err).to.be.a 'null'

          broker.addBinding {type:'pubsub', src:outQueue, tgt:inQueue}, (err) ->
            chai.expect(err).to.be.a 'null'

            receiver.subscribeToQueue inQueue, onReceive, (err) ->
              chai.expect(err).to.be.a 'null'
            sender.sendToQueue outQueue, payload, (err) ->
              chai.expect(err).to.be.a 'null'



  'MQTT': 'mqtt://localhost'
  'AMQP': 'amqp://localhost'


zip = () ->
  lengthArray = (arr.length for arr in arguments)
