   'MQTT': 'mqtt://localhost'
   'AMQP': 'amqp://localhost'
 
-
-connectAll = (clients, callback) ->
-  connect = (c, cb) ->
-    c.connect cb
-
-  async.map clients, connect, callback
 
 zip = () ->
   lengthArray = (arr.length for arr in arguments)

    client.subscribeToQueue queue, ackHandler, cb

  async.map handlers, sub, callback

transportTests = (type) ->
  address = transports[type]
  broker = null

        chai.expect(msg).to.include.keys 'data'
        chai.expect(msg.data).to.eql payload
        done()
      createConnectClients ['sender', 'receiver'], (err) ->
        clients.receiver.createQueue 'inqueue', inQueue, (err) ->
          chai.expect(err).to.be.a 'null'
          clients.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'

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


