anchor.diff:                   #state{queues = Queues,
                           service = Service} = State) ->
       Queue = cloudi_x_trie:fetch(QueueName, Queues),
  -    #queue{service_id = ServiceId} = Queue,
  +    #queue{service_id = ServiceId,
  +           terminate = Terminate} = Queue,
       case cloudi_service_api:service_subscriptions(ServiceId, infinity) of
           {error, not_found} ->
               PurgeQueue = purge_queue(Reason, State),
  
positive.code:             end,
              QueueNew = Queue#queue{terminate_timer = TerminateTimer},
              State#state{queues = cloudi_x_trie:store(QueueName,
                                                       QueueNew, Queues)}
      end.
  
  running_stopped(true, QueueName,
  
negative.code:             QueuesNew = cloudi_x_trie:store(QueueName, QueueNew, Queues),
              running_stopped(PurgeQueue, QueueName,
                              State#state{queues = QueuesNew});
          _ when Terminate =:= true ->
              TimeoutNew = Timeout - ?TERMINATE_INTERVAL,
              TerminateTimer = if
                  TimeoutNew > 0 ->
  