anchor.diff:              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 ->
  
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:                  #state{queues = Queues,
                          service = Service} = State) ->
      Queue = cloudi_x_trie:fetch(QueueName, Queues),
      #queue{service_id = ServiceId,
             terminate = Terminate} = Queue,
      case cloudi_service_api:service_subscriptions(ServiceId, infinity) of
          {error, not_found} ->
              PurgeQueue = purge_queue(Reason, State),
  