D-Net

    private static final Log log = LogFactory.getLog(DataciteCollectorPlugin.class);

    private DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd");

    @Override

    public Iterable<String> collect(InterfaceDescriptor interfaceDescriptor, String fromDate, String untilDate) throws CollectorServiceException {

        String baseurl = interfaceDescriptor.getBaseUrl();

        if(StringUtils.isBlank(baseurl)) throw new CollectorServiceException("baseUrl cannot be empty");

        long timestamp= 0;

        if (StringUtils.isNotBlank(fromDate)) {

            try {

                Date date =  org.apache.commons.lang.time.DateUtils.parseDate(

                         fromDate,

                         new String[] { "yyyy-MM-dd", "yyyy-MM-dd'T'HH:mm:ssXXX", "yyyy-MM-dd'T'HH:mm:ss.SSSX", "yyyy-MM-dd'T'HH:mm:ssZ",

                                 "yyyy-MM-dd'T'HH:mm:ss.SX" });

               timestamp =  date.toInstant().toEpochMilli();

                log.info("Querying for Datacite records from timestamp "+timestamp+" (date was "+fromDate+")");

            } catch (ParseException e) {

                throw new CollectorServiceException(e);

            }

        }

        final long finalTimestamp = timestamp;

        return () -> {

            try {

                return new DataciteESIterator(finalTimestamp, baseurl);

            } catch (Exception e) {

                throw new RuntimeException(e );

            }

        };

    }