D-Net

		final String rsId = serviceResolver.getResourceIdentifier(epr);

		try {

			// TODO: change to a getRSStatus call, getNumberOfElements could be potentially slow (ticket #1569)

			resultSet.getNumberOfElements(rsId);

import eu.dnetlib.functionality.index.feed.FeedMode;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Required;

import java.util.UUID;

        handler.ongoing(job);

        log.info("FEED job set to ONGOING");

        final String epr = getEpr(job);

        final String triggerId = UUID.randomUUID().toString();

        final String dsId = getIndexDSId(job);

     * @return a new org.quartz.SimpleTrigger instance.

     */

    private SimpleTrigger getResultsetTrigger(final String rsEpr, final String triggerId) {

        trigger.getJobDataMap().put(BBParam.RS_EPR, rsEpr);

        trigger.setJobName(ResultsetKeepAliveJob.JOB_NAME);

        trigger.setJobGroup(ResultsetKeepAliveJob.JOB_GROUP);

            public void unschedule() {

                try {

                    log.info("\n\n unscheduling resultSet keepalive trigger: " + triggerId + "\n\n");

                } catch (SchedulerException e) {

                    log.warn("cannot unschedule RSKeepAlive triggerId: " + triggerId);

                    throw new RuntimeException(e); // NOPMD

		</property>

	</bean>

		p:jobClass="eu.dnetlib.functionality.index.actors.ResultsetKeepAliveJob"

		p:name="resultsetKeepaliveJob" p:group="keepalive" p:durability="true">

		<property name="jobDataAsMap">

	<modelVersion>4.0.0</modelVersion>

	<parent>

		<groupId>eu.dnetlib</groupId>

	</parent>

	<groupId>eu.dnetlib</groupId>

	<artifactId>dnet-modular-index-service</artifactId>

	<version>2.5.1-SNAPSHOT</version>

	<scm>

	</scm>

	<repositories>

		<!-- repo for Akka Actors -->