 
   # HELPERS #
   bindToWorkerQueue: (exchangeName, callback) ->
-    console.log "binding queue #{@queueName} to exchange #{exchangeName}"
     workerQueueOptions =
       exchangeAutoDelete: false
       queueExclusive: false

    accountId = activity.originId
    accountXName = @getExchangeName accountId
    # Setting deliveryMode to 2 makes the message persistent.
    options = 
      deliveryMode: 2
      autoDelete: false
    payload = activity._id.toString()

    @bindToWorkerQueue accountXName, =>
      @emitActivity accountXName, payload, options

    activity.fetchTeaser (err, {tags}) =>
      return unless tags?

        do =>
          tagXName = @getExchangeName tag._id
          @bindToWorkerQueue tagXName, =>
            @emitActivity tagXName, payload, {deliveryMode, autoDelete}

  handleFollowAction: (account) ->
    ownExchangeName = @getExchangeName account._id
