419
return nil, err
420
}
421
>
queues = append(queues, persistence.QueueInfo{
queue_v2.go
422
>
QueueName: row.QueueName,
423
>
MessageCount: messageCount,
424
>
LastMessageID: lastMessageID,
425
>
})
426
}
427
>
lastReadQueueNumber := offset + int64(len(queues))
queue_v2.go
428
>
var nextPageToken []byte
429
>
if len(queues) > 0 {
430
>
nextPageToken = persistence.GetNextPageTokenForListQueues(lastReadQueueNumber)
431
>
}
432
>
response := &persistence.InternalListQueuesResponse{
433
>
Queues: queues,
434
>
NextPageToken: nextPageToken,
435
>
}
436
>
return response, nil
437
}
438