       @broker.addBinding {type: 'pubsub', src: port.queue, tgt: readQueue}, (err) =>
         return callback err if err
         @broker.subscribeToQueue readQueue, ackHandler, (err) ->
-          console.log '!! subscribed'
           return callback err, readQueue # caller should teardown readQueue
 
   unsubscribeFrom: () -> # FIXME: implement


      if direction.indexOf('out') == 0
        handler = (msg) =>
          console.log 'got exported outport data on', external
          @emit 'exported-port-data', external, msg.data, graph
        @subscribeTo node, internal, handler, (err, readQueue) ->
          return callback err if err

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

    debug 'subscribeTo', participantId, outport
    port = findPort part, 'outport', outport
    ackHandler = (msg) =>
      return if not @started
      handler msg
