})
t.Run("TestEnqueueMessageToNonExistentQueue", func(t *testing.T) {
_, err := q.EnqueueMessage(ctx, &persistence.InternalEnqueueMessageRequest{
QueueType: queueType,
QueueName: "non-existent-queue",
})
assert.ErrorAs(t, err, new(*serviceerror.NotFound))
assert.ErrorContains(t, err, "non-existent-queue")
assert.ErrorContains(t, err, strconv.Itoa(int(queueType)))
})
t.Run("TestCreateQueueTwice", func(t *testing.T) {
t.Parallel()