72
})
73
t.Run("TestCreateQueueTwice", func(t *testing.T) {
75
>
76
>
_, err := q.CreateQueue(ctx, &persistence.InternalCreateQueueRequest{
77
>
QueueType: queueType,
78
>
QueueName: queueName,
79
>
})
80
>
require.Error(t, err)
81
>
assert.ErrorIs(t, err, persistence.ErrQueueAlreadyExists)
82
>
assert.ErrorContains(t, err, strconv.Itoa(int(queueType)))
83
>
assert.ErrorContains(t, err, queueName)
84
>
})
85
t.Run("InvalidEncodingForQueueMessage", func(t *testing.T) {
86
queueType := persistence.QueueTypeHistoryNormal