err = queue.Close(context.Background())