     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
 

fromIipId = (id) ->
  return id.split ' '


waitForParticipant = (coordinator, role, callback) ->
  existing = coordinator.participantsByRole role
  return callback null, coordinator.participants[existing[0]] if existing.length

  onTimeout = () =>

  connect: (fromId, fromPort, toId, toName, callback) ->
    callback = ((err) ->) if not callback
 
    # NOTE: adding partial connection info to make checkParticipantConnections logic work
    edgeId = connId fromId, fromPort, toId, toName
    edge =
