})
t.Run("InvalidNextPageToken", func(t *testing.T) {
queueType := persistence.QueueTypeHistoryDLQ
_, err := listqueues.Invoke(
context.Background(),
manager,
&historyservice.ListQueuesRequest{
QueueType: int32(queueType),
PageSize: 1,
NextPageToken: []byte("invalid_token"),
},
)
require.Error(t, err)
})
}