 
   unsubscribeGroup: (groupId) =>
     debug 'unsubscribeGroup', groupId
-    redis.del "repeat/#{groupId}"
+    redis.del "active/#{groupId}"
     redis.smembers "groups/#{groupId}", (err, targetIds) =>
       debug 'unsubscribeGroup found', err, targetIds
       _.each targetIds, (targetId) =>

    @unsubscribeTarget groupId, targetId, =>
      redis.sadd "groups/#{groupId}", targetId
      redis.mset
        "repeat/#{groupId}": true
        "repeat/#{targetId}": true

      job = @queue.create('interval', {
          groupId: groupId,

          intervalTime: intervalTime
        }).
        removeOnComplete(true).
        attempts(process.env.INTERVAL_ATTEMPTS ? 999).
        ttl(process.env.INTERVAL_TTL ? 10000).
        save =>
          redis.set "job/#{targetId}", job.id
          debug ' - created job', job.id, 'for', targetId
