104
})
105
t.Run("InvalidEncodingForQueueMetadata", func(t *testing.T) {
107
>
queueName := "test-queue-" + t.Name()
108
>
_, err := q.CreateQueue(ctx, &persistence.InternalCreateQueueRequest{
109
>
QueueType: queueType,
110
>
QueueName: queueName,
111
>
})
112
>
require.NoError(t, err)
113
>
_, err = persistencetest.EnqueueMessage(context.Background(), q, queueType, queueName, func(p *persistencetest.EnqueueParams) {
114
>
p.EncodingType = -1
115
>
})
116
>
require.NoError(t, err)
117
>
_, err = q.ReadMessages(ctx, &persistence.InternalReadMessagesRequest{
118
>
QueueType: queueType,
119
>
QueueName: queueName,
120
>
PageSize: 10,
121
>
})
122
>
require.Error(t, err)
123
>
assert.ErrorAs(t, err, new(*serialization.UnknownEncodingTypeError))
124
})
125
t.Run("TestRangeDeleteMessages", func(t *testing.T) {