D-Net

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet40/modules/cnr-notifications-common/trunk/", "deploy_repository": "dnet4-snapshots", "version": "4", "mail": "sandro.labruzzo@isti.cnr.it,michele.artini@isti.cnr.it, claudio.atzori@isti.cnr.it, alessia.bardi@isti.cnr.it", "deploy_repository_url": "http://maven.research-infrastructures.eu/nexus/content/repositories/dnet4-snapshots", "name": "cnr-notifications-common"}

package eu.dnetlib.enabling.actions;

import eu.dnetlib.enabling.tools.blackboard.NotificationHandler;

/**

 * Manager subscription action.

 *

 * @author marko

 *

 */

public interface SubscriptionAction extends NotificationHandler {

	/**

	 * topic expression associated with this subscription action.

	 *

	 * @return SN topic expression

	 */

	String getTopicExpression();

	/**

	 * react on this topic prefix. Might be shorter than the topic expression.

	 *

	 * @return SN topic prefix

	 */

	String getTopicPrefix();

}

package eu.dnetlib.enabling.actions;

import javax.annotation.PostConstruct;

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

import eu.dnetlib.enabling.actions.SubscriptionAction;

import eu.dnetlib.enabling.tools.Enableable;

/**

 * Common subscription action.

 *

 * @author marko

 *

 */

public abstract class AbstractSubscriptionAction implements SubscriptionAction, Enableable {

	/**

	 * topic expression.

	 */

	private String topicExpression;

	/**

	 * topic prefix.

	 */

	private String topicPrefix;

	/**

	 * true if enabled.

	 */

	private boolean enabled = true;

	/**

	 * init the default topic prefix.

	 */

	@PostConstruct

	public void init() {

		if (topicPrefix == null)

			topicPrefix = getTopicExpression().replace("/", ".");

	}

	@Override

	public String getTopicExpression() {

		return topicExpression;

	}

	@Required

	public void setTopicExpression(final String topicExpression) {

		this.topicExpression = topicExpression;

	}

	@Override

	public String getTopicPrefix() {

		return topicPrefix;

	}

	public void setTopicPrefix(final String topicPrefix) {

		this.topicPrefix = topicPrefix;

	}

	@Override

	public boolean isEnabled() {

		return enabled;

	}

	@Override

	public void setEnabled(boolean enabled) {

		this.enabled = enabled;

	}

}

package eu.dnetlib.enabling.tools;

import java.text.ParseException;

import javax.annotation.PostConstruct;

import javax.annotation.Resource;

import org.quartz.CronExpression;

import org.quartz.CronTrigger;

import org.quartz.Job;

import org.quartz.JobDataMap;

import org.quartz.JobDetail;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.quartz.Trigger;

import org.springframework.beans.factory.BeanNameAware;

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

/**

 * Common implementation for schedulable beans.

 * 

 * @author claudio

 * 

 */

public abstract class AbstractSchedulable implements Schedulable, Job, BeanNameAware {

	private static final String THIS = "this";

	private final static String GROUP = "schedulableJobs";

	private boolean enabled;

	private CronExpression cronExpression;

	private String beanName;

	@Resource(name = "dnetJobScheduler")

	private Scheduler jobScheduler;

	@PostConstruct

	protected void init() {

		try {

			JobDataMap jobDataMap = new JobDataMap();

			jobDataMap.put(THIS, this);

			JobDetail jd = new JobDetail();

			jd.setName(getBeanName());

			jd.setGroup(GROUP);

			jd.setJobDataMap(jobDataMap);

			jd.setJobClass(this.getClass());

			jobScheduler.scheduleJob(jd, createTrigger());

		} catch (SchedulerException e) {

			throw new RuntimeException(e);

		}

	}

	private Trigger createTrigger() {

		try {

			CronTrigger trigger = new CronTrigger(getBeanName(), GROUP, getCronExpression());

			trigger.setMisfireInstruction(Trigger.INSTRUCTION_NOOP);

			trigger.setJobGroup(GROUP);

			trigger.setJobName(getBeanName());

			return trigger;

		} catch (ParseException e) {

			throw new IllegalArgumentException("invalid cron expression: " + cronExpression, e);

		}

	}

	protected abstract void doExecute();

	@Override

	public void execute() {

		// bean represents the quartz instance of this object

		if (isEnabled()) {

			doExecute();

		}

	}

	@Override

	public void execute(JobExecutionContext context) throws JobExecutionException {

		AbstractSchedulable bean = (AbstractSchedulable) context.getJobDetail().getJobDataMap().get(THIS);

		// bean represents the quartz instance of this object

		if (bean.isEnabled()) {

			bean.doExecute();

		}

	}

	@Override

	public boolean isEnabled() {

		return enabled;

	}

	@Override

	public void setEnabled(boolean enabled) {

		this.enabled = enabled;

	}

	@Override

	public String getCronExpression() {

		return cronExpression.getCronExpression();

	}

	@Required

	public void setCronExpression(String cronExpression) {

		try {

			this.cronExpression = new CronExpression(cronExpression);

		} catch (ParseException e) {

			throw new IllegalArgumentException("invalid cron expression: " + cronExpression, e);

		}

	}

	@Override

	public void updateCronExpression(String cronExpression) {

		if (!cronExpression.equals(getCronExpression())) {

			setCronExpression(cronExpression);

			try {

				jobScheduler.rescheduleJob(getBeanName(), GROUP, createTrigger());

			} catch (SchedulerException e) {

				throw new RuntimeException("unable to reschedule trigger", e);

			}

		}

	}

	@Override

	public String getNextFireTime() {

		try {

			if (isPaused()) {

				return "";

			}

			if (!isEnabled()) {

				return "";

			}

			Trigger t = jobScheduler.getTrigger(getBeanName(), GROUP);

			return t != null ? t.getNextFireTime().toString() : "";

		} catch (SchedulerException e) {

			throw new RuntimeException("unable to get trigger", e);

		}

	}

	@Override

	public boolean isPaused() {

		try {

			int state = jobScheduler.getTriggerState(getBeanName(), GROUP);

			switch (state) {

			case Trigger.STATE_PAUSED:

			case Trigger.STATE_NONE:

			case Trigger.STATE_ERROR:

				return true;

			default:

				return false;

			}

		} catch (SchedulerException e) {

			throw new RuntimeException("unable to get trigger", e);

		}

	}

	@Override

	public void pause() {

		try {

			jobScheduler.pauseTrigger(getBeanName(), GROUP);

		} catch (SchedulerException e) {

			throw new RuntimeException("unable to pause trigger", e);

		}

	}

	@Override

	public void resume() {

		try {

			jobScheduler.resumeTrigger(getBeanName(), GROUP);

		} catch (SchedulerException e) {

			throw new RuntimeException("unable to resume trigger", e);

		}

	}

	public String getBeanName() {

		return beanName;

	}

	@Override

	@Required

	public void setBeanName(String beanName) {

		this.beanName = beanName;

	}

}

package eu.dnetlib.enabling.tools;

import javax.annotation.Resource;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import eu.dnetlib.enabling.is.registry.rmi.ISRegistryException;

import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

/**

 * Schedulable implementation of an xUpdate.

 * 

 * @author claudio

 * 

 */

public class SchedulableProfileUpdater extends AbstractSchedulable {

	private static final Log log = LogFactory.getLog(SchedulableProfileUpdater.class); // NOPMD by marko on 11/24/08 5:02 PM

	private String xUpdate;

	@Resource

	private UniqueServiceLocator serviceLocator;

	@Override

	protected void doExecute() {

		try {

			log.info("triggering scheduled reindex: " + getxUpdate());

			serviceLocator.getService(ISRegistryService.class).executeXUpdate(getxUpdate());

		} catch (ISRegistryException e) {

			throw new RuntimeException(e);

		}

	}

	public String getxUpdate() {

		return xUpdate;

	}

	@Required

	public void setxUpdate(String xUpdate) {

		this.xUpdate = xUpdate;

	}

}

package eu.dnetlib.enabling.tools.blackboard;

import eu.dnetlib.miscutils.datetime.DateUtils;

public class NotificationInfo {

	private String name;

	private String subscrId;

	private String topic;

	private String rsId;

	private String profile;

	private String date;

	public NotificationInfo() {	

		this.date = DateUtils.now_ISO8601();

	}

	public NotificationInfo(String name, String subscrId, String topic, String rsId, String profile) {

		super();

		this.name = name;

		this.subscrId = subscrId;

		this.topic = topic;

		this.rsId = rsId;

		this.profile = profile;

		this.date = DateUtils.now_ISO8601();

	}

	public String getName() {

		return name;

	}

	public void setName(String name) {

		this.name = name;

	}

	public String getSubscrId() {

		return subscrId;

	}

	public void setSubscrId(String subscrId) {

		this.subscrId = subscrId;

	}

	public String getTopic() {

		return topic;

	}

	public void setTopic(String topic) {

		this.topic = topic;

	}

	public String getRsId() {

		return rsId;

	}

	public void setRsId(String rsId) {

		this.rsId = rsId;

	}

	public String getProfile() {

		return profile;

	}

	public void setProfile(String profile) {

		this.profile = profile;

	}

	public String getDate() {

		return date;

	}

	public void setDate(String date) {

		this.date = date;

	}

}

package eu.dnetlib.enabling.tools.blackboard;

/**

 * Each service may have a chain of NotificationHandlers, which process incoming notifications.

 * 

 * @author marko

 *

 */

public interface NotificationHandler {

	/**

	 * Incoming notification received.

	 * 

	 * @param subscrId subscriptionId

	 * @param topic topic

	 * @param rsId resource id

	 * @param profile resource profile

	 */

	void notified(String subscrId, final String topic, final String rsId, final String profile);

}

package eu.dnetlib.enabling.tools.blackboard;

/**

 * Invokes a chain of notification handlers for each incoming notification. Normally an instance of this class is

 * registered as the notification handler for a given service.

 * 

 * @author marko

 * 

 */

public interface NotificationHandlerChain extends NotificationHandler {

	public void delegateNotification(final String subscrId, final String topic, final String rsId, final String profile, final NotificationHandler handler);

}

package eu.dnetlib.enabling.tools.blackboard;

import java.util.Map;

public interface NotificationHistory {

	/**

	 * Return a saved notification associated to a bean and to a rsId.

	 * 

	 * @param name

	 * @return

	 */

	public NotificationInfo obtainNotification(String bean, String rsId);

	/**

	 * Save a notification.

	 * 

	 * @param info

	 */

	void saveNotification(NotificationInfo info);

	/**

	 * Return all saved notifications.

	 * 

	 * @return

	 */

	Map<String, Map<String, NotificationInfo>> obtainAllNotifications();

	/**

	 * Remove a saved notifications.

	 * 

	 * @return

	 */

	public void clearNotification(String bean, String rsId);

}

package eu.dnetlib.enabling.tools.blackboard;

import java.util.Collection;

import java.util.Map;

import javax.annotation.Resource;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import org.springframework.core.task.TaskExecutor;

import eu.dnetlib.enabling.actions.AbstractSubscriptionAction;

import eu.dnetlib.enabling.tools.Enableable;

import eu.dnetlib.enabling.tools.EnableableEnumerator;

public class NotificationHandlerChainImpl implements NotificationHandlerChain {

	/**

	 * logger.

	 */

	private static final Log log = LogFactory.getLog(NotificationHandlerChain.class); // NOPMD by marko on 11/24/08 5:02 PM

	/**

	 * notification handler chain.

	 */

	private Collection<NotificationHandler> handlers;

	/**

	 * task executor used for invoking the handlers.

	 */

	private TaskExecutor handlerExecutor;

	@Resource

	private NotificationHistory notificationHistory;

	@Resource

	private EnableableEnumerator enableableEnumerator;

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.enabling.tools.blackboard.NotificationHandler#notified(java.lang.String, java.lang.String,

	 *      java.lang.String, java.lang.String)

	 */

	@Override

	public void notified(final String subscrId, final String topic, final String rsId, final String profile) {

		for (final NotificationHandler handler : handlers) {

			try {

				if (handler instanceof AbstractSubscriptionAction)

					if (topic.startsWith(((AbstractSubscriptionAction) handler).getTopicPrefix()))

						if (!((Enableable) handler).isEnabled()) {

							for (Map.Entry<String, Enableable> entry : enableableEnumerator.getAllEnableables().entrySet()) {

								if (entry.getValue() == handler) {

									NotificationInfo info = new NotificationInfo();

									info.setName(entry.getKey());

									info.setProfile(profile);

									info.setRsId(rsId);

									info.setSubscrId(subscrId);

									info.setTopic(topic);

									notificationHistory.saveNotification(info);

								}

							}

							continue;

						}

				delegateNotification(subscrId, topic, rsId, profile, handler);

			} catch (final RuntimeException e) {

				log.fatal("error processing notification handler " + handler, e);

			}

		}

	}

	@Override

	public void delegateNotification(final String subscrId, final String topic, final String rsId, final String profile, final NotificationHandler handler) {

		handlerExecutor.execute(new Runnable() {

			@Override

			public void run() {

				handler.notified(subscrId, topic, rsId, profile);

			}

		});

	}

	public Collection<NotificationHandler> getHandlers() {

		return handlers;

	}

	@Required

	public void setHandlers(final Collection<NotificationHandler> handlers) {

		this.handlers = handlers;

	}

	public TaskExecutor getHandlerExecutor() {

		return handlerExecutor;

	}

	@Required

	public void setHandlerExecutor(TaskExecutor handlerExecutor) {

		this.handlerExecutor = handlerExecutor;

	}

}

package eu.dnetlib.enabling.tools.blackboard;

import java.util.HashMap;

import java.util.Map;

public class NotificationHistoryImpl implements NotificationHistory {

	private Map<String, Map<String, NotificationInfo>> notifications = new HashMap<String, Map<String, NotificationInfo>>();

	@Override

	public NotificationInfo obtainNotification(String bean, String rsId) {

		if (!notifications.containsKey(bean))

			return null;

		return notifications.get(bean).get(rsId);

	}

	@Override

	public void saveNotification(NotificationInfo info) {

		String bean = info.getName();

		String rsId = info.getRsId();

		if (!notifications.containsKey(bean))

			notifications.put(bean, new HashMap<String, NotificationInfo>());

		notifications.get(bean).put(rsId, info);

	}

	@Override

	public Map<String, Map<String, NotificationInfo>> obtainAllNotifications() {

		return notifications;

	}

	@Override

	public void clearNotification(String bean, String rsId) {

		if (notifications.containsKey(bean))

			notifications.get(bean).remove(rsId);

	}

}

package eu.dnetlib.enabling.tools;

/**

 * Simple interface for classes, which's objects can be enabled or disabled.

 * 

 * 

 * @author marko

 * 

 */

public interface Enableable {

	/**

	 * True if this object enabled.

	 * 

	 * @return if this object is currently enabled.

	 */

	boolean isEnabled();

	/**

	 * Enables of disables this object.

	 * 

	 * @param enabled

	 *            enabled

	 */

	void setEnabled(boolean enabled);

}

package eu.dnetlib.enabling.tools;

/**

 * Simple interface for classes, which's objects actions can be scheduled.

 * 

 * @author claudio

 */

public interface Schedulable extends Enableable {

	/**

	 * Updates the cron expression.

	 * 

	 * @param cronExpression

	 */

	void updateCronExpression(String cronExpression);

	/**

	 * Getter for the cron expression.

	 * 

	 * @return the String representing the cron expression.

	 */

	String getCronExpression();

	/**

	 * Computes the next time the doExecute method will be invoked.

	 * 

	 * @return the String representing the next fire time.

	 */

	String getNextFireTime();

	/**

	 * True if the object has been paused.

	 * 

	 * @return if the bean has been paused.

	 */

	boolean isPaused();

	/**

	 * Prevents the bean for being scheduled for future invocations.

	 */

	void pause();

	/**

	 * Resumes the bean for being scheduled for future invocations.

	 */

	void resume();

	/**

	 * Must be implemented to perform the real action.

	 */

	void execute();	

}

package eu.dnetlib.enabling.tools;

import java.util.Map;

import org.springframework.beans.BeansException;

import org.springframework.beans.factory.BeanFactory;

import org.springframework.beans.factory.BeanFactoryAware;

import org.springframework.beans.factory.ListableBeanFactory;

import org.springframework.beans.factory.NoSuchBeanDefinitionException;

/**

 * This bean has to live in the same bean factory where all enableables live. Thus it cannot be put inside the EnableablController, which

 * lives in the webContext.

 * 

 * @author marko

 * 

 */

public class EnableableEnumerator implements BeanFactoryAware {

	/**

	 * bean factory.

	 */

	private ListableBeanFactory beanFactory;

	/**

	 * Get all beans implementing the Enableable interface.

	 * 

	 * @return

	 */

	public Map<String, Enableable> getAllEnableables() {

		return beanFactory.getBeansOfType(Enableable.class);

	}

	@Override

	public void setBeanFactory(final BeanFactory beanFactory) throws BeansException {

		this.beanFactory = (ListableBeanFactory) beanFactory;

	}

	public ListableBeanFactory getBeanFactory() {

		return beanFactory;

	}

	/**

	 * Get given enableable or null.

	 * 

	 * @param name

	 * @return

	 */

	public Enableable getEnableable(final String name) {

		try {

			return beanFactory.getBean(name, Enableable.class);

		} catch (final NoSuchBeanDefinitionException e) {

			return null;

		}

	}

}

package eu.dnetlib.enabling.tools;

import java.util.Map;

import org.springframework.beans.BeansException;

import org.springframework.beans.factory.BeanFactory;

import org.springframework.beans.factory.BeanFactoryAware;

import org.springframework.beans.factory.ListableBeanFactory;

import org.springframework.beans.factory.NoSuchBeanDefinitionException;

/**

 * This bean has to live in the same bean factory where all schedulables live. Thus it cannot be put inside the EnableablController, which

 * lives in the webContext.

 * 

 * @author claudio

 * 

 */

public class SchedulableEnumerator implements BeanFactoryAware {

	/**

	 * bean factory.

	 */

	private ListableBeanFactory beanFactory;

	/**

	 * Get all beans implementing the Schedulable interface.

	 * 

	 * @return

	 */

	public Map<String, Schedulable> getAllSchedulables() {

		return beanFactory.getBeansOfType(Schedulable.class);

	}

	@Override

	public void setBeanFactory(final BeanFactory beanFactory) throws BeansException {

		this.beanFactory = (ListableBeanFactory) beanFactory;

	}

	public ListableBeanFactory getBeanFactory() {

		return beanFactory;

	}

	/**

	 * Get given schedulable or null.

	 * 

	 * @param name

	 * @return

	 */

	public Schedulable getSchedulable(final String name) {

		try {

			return beanFactory.getBean(name, Schedulable.class);

		} catch (final NoSuchBeanDefinitionException e) {

			return null;

		}

	}

}

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">

	<bean id="enableableEnumerator"

		class="eu.dnetlib.enabling.tools.EnableableEnumerator" />

	<bean id="notificationHistory"

		class="eu.dnetlib.enabling.tools.blackboard.NotificationHistoryImpl" />

</beans>

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws"

	xmlns:sec="http://cxf.apache.org/configuration/security" xmlns:wsa="http://cxf.apache.org/ws/addressing"

	xmlns:p="http://www.springframework.org/schema/p" xmlns:http="http://cxf.apache.org/transports/http/configuration"

	xmlns:t="http://dnetlib.eu/springbeans/t" xmlns:template="http://dnetlib.eu/springbeans/template"

	xmlns:util="http://www.springframework.org/schema/util"

	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

						http://cxf.apache.org/ws/addressing http://cxf.apache.org/schemas/ws-addr-conf.xsd

						http://cxf.apache.org/configuration/security http://cxf.apache.org/schemas/configuration/security.xsd

						http://cxf.apache.org/transports/http/configuration http://cxf.apache.org/schemas/configuration/http-conf.xsd

						http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd

						http://dnetlib.eu/springbeans/template http://dnetlib.eu/springbeans/template.xsd

						http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd">

	<bean id="dnetJobScheduler"

		class="org.springframework.scheduling.quartz.SchedulerFactoryBean"

		destroy-method="destroy">

		<property name="jobFactory">

			<bean id="jobSchedulerFactory"

				class="org.springframework.scheduling.quartz.SpringBeanJobFactory" />

		</property>

	</bean>

	<bean id="schedulableEnumerator"

		class="eu.dnetlib.enabling.tools.SchedulableEnumerator" />

</beans>

<?xml version="1.0" ?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

	<parent>

		<groupId>eu.dnetlib</groupId>

		<artifactId>dnet-parent</artifactId>

		<version>1.0.0</version>

		<relativePath />

	</parent>

	<modelVersion>4.0.0</modelVersion>

	<groupId>eu.dnetlib</groupId>

	<artifactId>cnr-notifications-common</artifactId>

	<packaging>jar</packaging>

	<version>2.1.1-SNAPSHOT</version>

	<scm>

	  <developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet40/modules/cnr-notifications-common/trunk</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-service-common</artifactId>

			<version>[2.1.0,3.0.0)</version>

		</dependency>

		<dependency>

			<groupId>org.springframework</groupId>

			<artifactId>spring-context-support</artifactId>

			<version>${spring.version}</version>

		</dependency>

		<dependency>

			<groupId>opensymphony</groupId>

			<artifactId>quartz</artifactId>

			<version>1.6.6</version>

		</dependency>

	</dependencies>

</project>

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet40/modules/cnr-notifications-common/trunk/", "deploy_repository": "dnet4-snapshots", "version": "4", "mail": "sandro.labruzzo@isti.cnr.it,michele.artini@isti.cnr.it, claudio.atzori@isti.cnr.it, alessia.bardi@isti.cnr.it", "deploy_repository_url": "http://maven.research-infrastructures.eu/nexus/content/repositories/dnet4-snapshots", "name": "cnr-notifications-common"}

package eu.dnetlib.enabling.actions;

import eu.dnetlib.enabling.tools.blackboard.NotificationHandler;

/**

 * Manager subscription action.

 *

 * @author marko

 *

 */

public interface SubscriptionAction extends NotificationHandler {

	/**

	 * topic expression associated with this subscription action.

	 *

	 * @return SN topic expression

	 */

	String getTopicExpression();

	/**

	 * react on this topic prefix. Might be shorter than the topic expression.

	 *

	 * @return SN topic prefix

	 */

	String getTopicPrefix();

}

package eu.dnetlib.enabling.actions;

import javax.annotation.PostConstruct;

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

import eu.dnetlib.enabling.actions.SubscriptionAction;

import eu.dnetlib.enabling.tools.Enableable;

/**

 * Common subscription action.

 *

 * @author marko

 *

 */

public abstract class AbstractSubscriptionAction implements SubscriptionAction, Enableable {

	/**

	 * topic expression.

	 */

	private String topicExpression;

	/**

	 * topic prefix.

	 */

	private String topicPrefix;

	/**

	 * true if enabled.

	 */

	private boolean enabled = true;

	/**

	 * init the default topic prefix.

	 */

	@PostConstruct

	public void init() {

		if (topicPrefix == null)

			topicPrefix = getTopicExpression().replace("/", ".");

	}

	@Override

	public String getTopicExpression() {

		return topicExpression;

	}

	@Required

	public void setTopicExpression(final String topicExpression) {

		this.topicExpression = topicExpression;

	}

	@Override

	public String getTopicPrefix() {

		return topicPrefix;

	}

	public void setTopicPrefix(final String topicPrefix) {

		this.topicPrefix = topicPrefix;

	}

	@Override

	public boolean isEnabled() {

		return enabled;

	}

	@Override

	public void setEnabled(boolean enabled) {

		this.enabled = enabled;

	}

}

package eu.dnetlib.enabling.tools;

import java.text.ParseException;

import javax.annotation.PostConstruct;

import javax.annotation.Resource;

import org.quartz.CronExpression;

import org.quartz.CronTrigger;

import org.quartz.Job;

import org.quartz.JobDataMap;

import org.quartz.JobDetail;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.quartz.Trigger;

import org.springframework.beans.factory.BeanNameAware;

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

/**

 * Common implementation for schedulable beans.

 * 

 * @author claudio

 * 

 */

public abstract class AbstractSchedulable implements Schedulable, Job, BeanNameAware {

	private static final String THIS = "this";

	private final static String GROUP = "schedulableJobs";

	private boolean enabled;

	private CronExpression cronExpression;

	private String beanName;

	@Resource(name = "dnetJobScheduler")

	private Scheduler jobScheduler;

	@PostConstruct

	protected void init() {

		try {

			JobDataMap jobDataMap = new JobDataMap();

			jobDataMap.put(THIS, this);

			JobDetail jd = new JobDetail();

			jd.setName(getBeanName());

			jd.setGroup(GROUP);

			jd.setJobDataMap(jobDataMap);

			jd.setJobClass(this.getClass());

			jobScheduler.scheduleJob(jd, createTrigger());

		} catch (SchedulerException e) {

			throw new RuntimeException(e);

		}

	}

	private Trigger createTrigger() {

		try {

			CronTrigger trigger = new CronTrigger(getBeanName(), GROUP, getCronExpression());

			trigger.setMisfireInstruction(Trigger.INSTRUCTION_NOOP);

			trigger.setJobGroup(GROUP);

			trigger.setJobName(getBeanName());

			return trigger;

		} catch (ParseException e) {

			throw new IllegalArgumentException("invalid cron expression: " + cronExpression, e);

		}

	}

	protected abstract void doExecute();

	@Override

	public void execute() {

		// bean represents the quartz instance of this object

		if (isEnabled()) {

			doExecute();

		}

	}

	@Override

	public void execute(JobExecutionContext context) throws JobExecutionException {

		AbstractSchedulable bean = (AbstractSchedulable) context.getJobDetail().getJobDataMap().get(THIS);

		// bean represents the quartz instance of this object

		if (bean.isEnabled()) {

			bean.doExecute();

		}

	}

	@Override

	public boolean isEnabled() {

		return enabled;

	}

	@Override

	public void setEnabled(boolean enabled) {

		this.enabled = enabled;

	}

	@Override

	public String getCronExpression() {

		return cronExpression.getCronExpression();

	}

	@Required

	public void setCronExpression(String cronExpression) {

		try {

			this.cronExpression = new CronExpression(cronExpression);

		} catch (ParseException e) {

			throw new IllegalArgumentException("invalid cron expression: " + cronExpression, e);

		}

	}

	@Override

	public void updateCronExpression(String cronExpression) {

		if (!cronExpression.equals(getCronExpression())) {

			setCronExpression(cronExpression);

			try {

				jobScheduler.rescheduleJob(getBeanName(), GROUP, createTrigger());

			} catch (SchedulerException e) {

				throw new RuntimeException("unable to reschedule trigger", e);

			}

		}

	}

	@Override

	public String getNextFireTime() {

		try {

			if (isPaused()) {

				return "";

			}

			if (!isEnabled()) {

				return "";

			}

			Trigger t = jobScheduler.getTrigger(getBeanName(), GROUP);

			return t != null ? t.getNextFireTime().toString() : "";

		} catch (SchedulerException e) {

			throw new RuntimeException("unable to get trigger", e);

		}

	}

	@Override

	public boolean isPaused() {

		try {

			int state = jobScheduler.getTriggerState(getBeanName(), GROUP);

			switch (state) {

			case Trigger.STATE_PAUSED:

			case Trigger.STATE_NONE:

			case Trigger.STATE_ERROR:

				return true;

			default:

				return false;

			}

		} catch (SchedulerException e) {

			throw new RuntimeException("unable to get trigger", e);

		}

	}

	@Override

	public void pause() {

		try {

			jobScheduler.pauseTrigger(getBeanName(), GROUP);

		} catch (SchedulerException e) {

			throw new RuntimeException("unable to pause trigger", e);

		}

	}

	@Override

	public void resume() {

		try {

			jobScheduler.resumeTrigger(getBeanName(), GROUP);

		} catch (SchedulerException e) {

			throw new RuntimeException("unable to resume trigger", e);

		}

	}

	public String getBeanName() {

		return beanName;

	}

	@Override

	@Required

	public void setBeanName(String beanName) {

		this.beanName = beanName;

	}

}

package eu.dnetlib.enabling.tools;

import javax.annotation.Resource;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import eu.dnetlib.enabling.is.registry.rmi.ISRegistryException;

import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;

/**

 * Schedulable implementation of an xUpdate.

 * 

 * @author claudio

 * 

 */

public class SchedulableProfileUpdater extends AbstractSchedulable {

	private static final Log log = LogFactory.getLog(SchedulableProfileUpdater.class); // NOPMD by marko on 11/24/08 5:02 PM

	private String xUpdate;

	@Resource

	private ServiceLocator<ISRegistryService> registryLocator;

	@Override

	protected void doExecute() {

		try {

			log.info("triggering scheduled reindex: " + getxUpdate());

			registryLocator.getService().executeXUpdate(getxUpdate());

		} catch (ISRegistryException e) {

			throw new RuntimeException(e);

		}

	}

	public String getxUpdate() {

		return xUpdate;

	}

	@Required

	public void setxUpdate(String xUpdate) {

		this.xUpdate = xUpdate;

	}

}

package eu.dnetlib.enabling.tools.blackboard;

import eu.dnetlib.miscutils.datetime.DateUtils;

public class NotificationInfo {

	private String name;

	private String subscrId;

	private String topic;

	private String rsId;

	private String profile;

	private String date;

	public NotificationInfo() {	

		this.date = DateUtils.now_ISO8601();

	}

	public NotificationInfo(String name, String subscrId, String topic, String rsId, String profile) {

		super();

		this.name = name;

		this.subscrId = subscrId;

		this.topic = topic;

		this.rsId = rsId;

		this.profile = profile;

		this.date = DateUtils.now_ISO8601();

	}

	public String getName() {

		return name;

	}

	public void setName(String name) {

		this.name = name;

	}

	public String getSubscrId() {

		return subscrId;

	}

	public void setSubscrId(String subscrId) {

		this.subscrId = subscrId;

	}

	public String getTopic() {

		return topic;

	}

	public void setTopic(String topic) {

		this.topic = topic;

	}

	public String getRsId() {

		return rsId;

	}

	public void setRsId(String rsId) {

		this.rsId = rsId;

	}

	public String getProfile() {

		return profile;

	}

	public void setProfile(String profile) {

		this.profile = profile;

	}

	public String getDate() {

		return date;

	}

	public void setDate(String date) {

		this.date = date;

	}

}

package eu.dnetlib.enabling.tools.blackboard;

/**

 * Each service may have a chain of NotificationHandlers, which process incoming notifications.

 * 

 * @author marko

 *

 */

public interface NotificationHandler {

	/**

	 * Incoming notification received.

	 * 

	 * @param subscrId subscriptionId

	 * @param topic topic

	 * @param rsId resource id

	 * @param profile resource profile

	 */

	void notified(String subscrId, final String topic, final String rsId, final String profile);

}

package eu.dnetlib.enabling.tools.blackboard;

/**

 * Invokes a chain of notification handlers for each incoming notification. Normally an instance of this class is

 * registered as the notification handler for a given service.

 * 

 * @author marko

 * 

 */

public interface NotificationHandlerChain extends NotificationHandler {

	public void delegateNotification(final String subscrId, final String topic, final String rsId, final String profile, final NotificationHandler handler);

}

package eu.dnetlib.enabling.tools.blackboard;

import java.util.Map;

public interface NotificationHistory {