                 # Bind all outqueues to same inqueue
                 queueMapping = []
                 for name in senders
-                  queueMapping.push [ clients[name], name, inQueue ]
+                  queueMapping.push [ clients[name], 'outqueue', name, inQueue ]
                 createBindQueues broker, queueMapping, (err) ->
                   chai.expect(err).to.not.exist
 


Coordinator = require('../src/coordinator').Coordinator
transport = require '../src/transport'
participants = require './fixtures/participants'

# Note: most require running an external broker service

    client.sendToQueue queue, data, cb

  async.map packets, send, callback

subscribeData = (handlers, callback) ->
  sub = (h, cb) ->
    [client, queue, handler] = h
    ackHandler = (msg) ->
      client.ackMessage msg
      return handler msg
    client.subscribeToQueue queue, ackHandler, cb

  async.map handlers, sub, callback


describe 'Transport', ->

