         do =>
           tagXName = @getExchangeName tag._id
           @bindToWorkerQueue tagXName, =>
-            @emitActivity tagXName, payload, options
+            @emitActivity tagXName, payload, {deliveryMode, autoDelete}
 
   handleFollowAction: (account) ->
     ownExchangeName = @getExchangeName account._id

    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?


  # HELPERS #
  bindToWorkerQueue: (exchangeName, callback) ->
    workerQueueOptions =
      exchangeAutoDelete: false
      queueExclusive: false
