receivedPeekBatch, err := queue.PeekBatch(context.Background(), "123", 3)