     callback = defaultCallback if not callback
 
     part = @participants[participantId]
-    part = @participants[@participantsByRole(participantId)] if not part?
+    part = @participants[participantsByRole(@participants, participantId)] if not part?
     port = findPort part, 'inport', inport
     return @broker.sendTo 'inqueue', port.queue, message, callback
 

    callback = defaultCallback if not callback

    part = @participants[participantId]
    part = @participants[@participantsByRole(participantId)] if not part?

    debug 'subscribeTo', participantId, outport
    port = findPort part, 'outport', outport

        @processes = proc
        setup.bindings options, callback


exports.Coordinator = Coordinator
