})
t.Run("TestNonPositivePageSize", func(t *testing.T) {
_, err := q.ReadMessages(ctx, &persistence.InternalReadMessagesRequest{
QueueType: queueType,
QueueName: queueName,
PageSize: 0,
NextPageToken: nil,
})
assert.ErrorIs(t, err, persistence.ErrNonPositiveReadQueueMessagesPageSize)
})
t.Run("TestEnqueueMessageToNonExistentQueue", func(t *testing.T) {
t.Parallel()