84
})
85
t.Run("InvalidEncodingForQueueMessage", func(t *testing.T) {
87
>
queueName := "test-queue-" + t.Name()
88
>
_, err := q.CreateQueue(ctx, &persistence.InternalCreateQueueRequest{
89
>
QueueType: queueType,
90
>
QueueName: queueName,
91
>
})
92
>
require.NoError(t, err)
93
>
_, err = persistencetest.EnqueueMessage(context.Background(), q, queueType, queueName, func(p *persistencetest.EnqueueParams) {
94
>
p.EncodingType = -1
95
>
})
96
>
require.NoError(t, err)
97
>
_, err = q.ReadMessages(ctx, &persistence.InternalReadMessagesRequest{
98
>
QueueType: queueType,
99
>
QueueName: queueName,
100
>
PageSize: 10,
101
>
})
102
>
require.Error(t, err)
103
>
assert.ErrorAs(t, err, new(*serialization.UnknownEncodingTypeError))
104
})
105
t.Run("InvalidEncodingForQueueMetadata", func(t *testing.T) {