Method Remove

client.go:2979–2988

Remove removes a queue from the client, stopping the producer if the client is running. It waits for any jobs currently being worked in the queue to complete before returning. If the provided context is done before the producer has fully stopped, Remove returns the context's error and does not full

(ctx context.Context, queueName string)

// Returns an error if the client is not configured to execute jobs or if the
// specified queue does not exist.
func (b *QueueBundle) Remove(ctx context.Context, queueName string) error {
	if !b.clientWillExecuteJobs {
		return errors.New("client is not configured to execute jobs, cannot remove queue")
	}

	b.startStopMu.Lock()
	defer b.startStopMu.Unlock()

	return b.producerRemove(ctx, queueName)
}

// Generates a default client ID using the current hostname and time.
func defaultClientID(startedAt time.Time) string {