code: func (consumer *Consumer) ResetWorking() error {
  	return consumer.Queue.redisClient.Del(consumerWorkingQueueKey(consumer.Queue.Name, consumer.Name)).Err()
  }
docs: // ResetWorking deletes! all messages in the working queue of this consumer