D-Net

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet40/modules/cnr-enabling-hcm-service/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-enabling-hcm-service"}

package eu.dnetlib.enabling.hcm.sn;

import java.util.List;

import org.springframework.beans.factory.FactoryBean;

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

import eu.dnetlib.enabling.actions.SubscriptionAction;

/**

 * This class acts as a simple registry of msro subscription actions.

 * 

 * <p>

 * Subscription actions are autodetected using spring autowiring from the current application context and are available for the manager for

 * handling subscriptions and delivering notification to particular code interested in those notifications.

 * </p>

 * 

 * @author marko

 * 

 */

@SuppressWarnings("rawtypes")

public class HCMSubscriptionListFactory implements FactoryBean {

	/**

	 * actions. Spring injects all the declared SubscriptionActions here.

	 */

	@Autowired(required = false)

	private List<SubscriptionAction> actions;

	public List<SubscriptionAction> getActions() {

		return actions;

	}

	public void setActions(final List<SubscriptionAction> actions) {

		this.actions = actions;

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see org.springframework.beans.factory.FactoryBean#getObject()

	 */

	@Override

	public Object getObject() {

		return getActions();

	}

	@Override

	public Class<?> getObjectType() {

		return null;

	}

	@Override

	public boolean isSingleton() {

		return false;

	}

}

package eu.dnetlib.enabling.hcm.sn;

import eu.dnetlib.enabling.is.sn.rmi.ISSNException;

/**

 * This component takes care of subscribing the MSRO service to interesting events.

 * 

 * @author marko

 *

 */

public interface HCMSubscriber {

	/**

	 * performs the subscription.

	 * @throws ISSNException could happen

	 */

	void subscribeAll() throws ISSNException;

}

package eu.dnetlib.enabling.hcm.sn;

import java.util.List;

import javax.annotation.PostConstruct;

import javax.annotation.Resource;

import javax.xml.ws.Endpoint;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import eu.dnetlib.enabling.actions.SubscriptionAction;

import eu.dnetlib.enabling.is.sn.rmi.ISSNException;

import eu.dnetlib.enabling.is.sn.rmi.ISSNService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.soap.EndpointReferenceBuilder;

/**

 * This component takes care of subscribing the SubscriptionAction(s) to interesting events.

 * 

 * @author claudio

 * 

 */

public class HCMSubscriberImpl implements HCMSubscriber {

	/**

	 * logger.

	 */

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

	/**

	 * notification endpoint (normally the msro service).

	 */

	private Endpoint endpoint;

	/**

	 * service locator.

	 */

	private UniqueServiceLocator serviceLocator;

	/**

	 * injected EPR builder.

	 */

	@Resource(name = "jaxwsEndpointReferenceBuilder")

	private EndpointReferenceBuilder<Endpoint> eprBuilder;

	/**

	 * subscription actions.

	 */

	private List<SubscriptionAction> actions;

	@PostConstruct

	public void printList() {

		log.info(getActions());

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @throws ISSNException

	 *             could happen

	 * @see eu.dnetlib.enabling.hcm.sn.HCMSubscriber#subscribeAll()

	 */

	@Override

	public void subscribeAll() throws ISSNException {

		final W3CEndpointReference endpointReference = eprBuilder

				.getEndpointReference(getEndpoint());

		if (getActions() != null) {

			for (final SubscriptionAction action : getActions()) {

				log.info("dynamically subscribing to "

						+ action.getTopicExpression());

				serviceLocator.getService(ISSNService.class, true).subscribe(endpointReference,

						action.getTopicExpression(), 0);

			}

		}

	}

	public void setEndpoint(final Endpoint endpoint) {

		this.endpoint = endpoint;

	}

	public Endpoint getEndpoint() {

		return endpoint;

	}

	public void setEprBuilder(

			final EndpointReferenceBuilder<Endpoint> eprBuilder) {

		this.eprBuilder = eprBuilder;

	}

	public EndpointReferenceBuilder<Endpoint> getEprBuilder() {

		return eprBuilder;

	}

	public List<SubscriptionAction> getActions() {

		return actions;

	}

	@Required

	public void setActions(final List<SubscriptionAction> actions) {

		this.actions = actions;

	}

	public UniqueServiceLocator getServiceLocator() {

		return serviceLocator;

	}

	@Required

	public void setServiceLocator(final UniqueServiceLocator serviceLocator) {

		this.serviceLocator = serviceLocator;

	}

}

package eu.dnetlib.enabling.hcm;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import eu.dnetlib.enabling.hcm.rmi.HostingContextManagerService;

import eu.dnetlib.enabling.tools.AbstractBaseService;

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

/**

 * CNR HostingContextManagerService implementation. Will conflict with NKUA! yes this is ok.

 * 

 * @author marko

 * 

 */

public class HostingContextManagerServiceImpl extends AbstractBaseService implements HostingContextManagerService {

	/**

	 * logger.

	 */

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

	/**

	 * notification handler.

	 */

	private NotificationHandler notificationHandler; // NOPMD

	@Override

	public void notify(String subscrId, String topic, String isId, String message) {

		if (log.isDebugEnabled()) {

			log.debug("---- service got notification ----");

			log.debug("subscrId: " + subscrId);

			log.debug("topic " + topic);

			log.debug("isId " + isId);

			log.debug("msg: " + message);

			log.debug("____ now processing the notification ____");

		}

		getNotificationHandler().notified(subscrId, topic, isId, message);

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.enabling.tools.AbstractBaseService#start()

	 */

	@Override

	public void start() {

		log.info("staring hosting context manager");

	}

	public NotificationHandler getNotificationHandler() {

		return notificationHandler;

	}

	@Required

	public void setNotificationHandler(NotificationHandler notificationHandler) {

		this.notificationHandler = notificationHandler;

	}

}

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

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

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

	xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

	xmlns:util="http://www.springframework.org/schema/util" xmlns:template="http://dnetlib.eu/springbeans/template"

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

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

		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.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.xsd">

	<!--  beans -->

	<bean id="hcmService"

		class="eu.dnetlib.enabling.hcm.HostingContextManagerServiceImpl"

		init-method="start" destroy-method="stop"  

		p:notificationHandler-ref="hcmNotificationHandler"/>

	<bean id="hcmNotificationHandler" class="eu.dnetlib.enabling.tools.blackboard.NotificationHandlerChainImpl"

		p:handlers-ref="dynamicSubscriptionActions">

		<property name="handlerExecutor">

			<bean class="org.springframework.core.task.SyncTaskExecutor" />

		</property>

	</bean>

	<bean id="dynamicSubscriptionActions"

		class="eu.dnetlib.enabling.hcm.sn.HCMSubscriptionListFactory" />

	<bean id="hcmSubscriber" class="eu.dnetlib.enabling.hcm.sn.HCMSubscriberImpl"

		p:endpoint-ref="hcmServiceEndpoint" p:serviceLocator-ref="uniqueServiceLocator" 

		p:actions-ref="dynamicSubscriptionActions" />

	<bean t:id="hcmJobSchedulerAccessor"

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

		p:scheduler-ref="jobScheduler">

		<property name="triggers">

			<list>

				<bean id="hcmSubscriptionTrigger"

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

					p:startDelay="6000" p:repeatCount="0">

					<property name="jobDetail">

						<bean id="hcmSubscriptionJobDetails"

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

							p:targetObject-ref="hcmSubscriber" p:targetMethod="subscribeAll" />

					</property>

				</bean>

			</list>

		</property>

	</bean>				

	<!-- endpoints -->

	<jaxws:endpoint id="hcmServiceEndpoint" implementor="#hcmService"

		implementorClass="eu.dnetlib.enabling.hcm.rmi.HostingContextManagerService"

		address="/hcm" />

	<template:instance name="serviceRegistrationManager"

		t:serviceRegistrationManagerClass="eu.dnetlib.enabling.tools.registration.ValidatingServiceRegistrationManagerImpl"

		t:name="hcmServiceRegistrationManager" t:service="hcmService"

		t:endpoint="hcmServiceEndpoint" t:jobScheduler="jobScheduler" />

</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-enabling-hcm-service</artifactId>

	<packaging>jar</packaging>

	<version>2.0.1-SNAPSHOT</version>

	<scm>

		<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet40/modules/cnr-enabling-hcm-service/trunk</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

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

			<version>[2.0.0, 3.0.0)</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-enabling-hcm-service/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-enabling-hcm-service"}

package eu.dnetlib.enabling.hcm.sn;

import java.util.List;

import javax.annotation.Resource;

import org.springframework.beans.factory.FactoryBean;

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

import eu.dnetlib.enabling.actions.SubscriptionAction;

/**

 * This class acts as a simple registry of msro subscription actions.

 * 

 * <p>

 * Subscription actions are autodetected using spring autowiring from the current application context and are available for the manager for

 * handling subscriptions and delivering notification to particular code interested in those notifications.

 * </p>

 * 

 * @author marko

 * 

 */

@SuppressWarnings("rawtypes")

public class HCMSubscriptionListFactory implements FactoryBean {

	/**

	 * actions. Spring injects all the declared SubscriptionActions here.

	 */

	@Autowired(required=false)

	private List<SubscriptionAction> actions;

	public List<SubscriptionAction> getActions() {

		return actions;

	}

	public void setActions(final List<SubscriptionAction> actions) {

		this.actions = actions;

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see org.springframework.beans.factory.FactoryBean#getObject()

	 */

	@Override

	public Object getObject() {

		return getActions();

	}

	@Override

	public Class<?> getObjectType() {

		return null;

	}

	@Override

	public boolean isSingleton() {

		return false;

	}

}

package eu.dnetlib.enabling.hcm.sn;

import eu.dnetlib.enabling.is.sn.rmi.ISSNException;

/**

 * This component takes care of subscribing the MSRO service to interesting events.

 * 

 * @author marko

 *

 */

public interface HCMSubscriber {

	/**

	 * performs the subscription.

	 * @throws ISSNException could happen

	 */

	void subscribeAll() throws ISSNException;

}

package eu.dnetlib.enabling.hcm.sn;

import java.util.List;

import javax.annotation.PostConstruct;

import javax.annotation.Resource;

import javax.xml.ws.Endpoint;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import eu.dnetlib.enabling.actions.SubscriptionAction;

import eu.dnetlib.enabling.is.sn.rmi.ISSNException;

import eu.dnetlib.enabling.is.sn.rmi.ISSNService;

import eu.dnetlib.enabling.tools.ServiceLocator;

import eu.dnetlib.soap.EndpointReferenceBuilder;

/**

 * This component takes care of subscribing the SubscriptionAction(s) to

 * interesting events.

 *

 * @author claudio

 *

 */

public class HCMSubscriberImpl implements HCMSubscriber {

	/**

	 * logger.

	 */

	private static final Log log = LogFactory.getLog(HCMSubscriberImpl.class); // NOPMD

																				// by

																				// marko

																				// on

																				// 11/24/08

																				// 5:02

																				// PM

	/**

	 * notification endpoint (normally the msro service).

	 */

	private Endpoint endpoint;

	/**

	 * is sn locator.

	 */

	private ServiceLocator<ISSNService> snLocator;

	/**

	 * injected EPR builder.

	 */

	@Resource(name = "jaxwsEndpointReferenceBuilder")

	private EndpointReferenceBuilder<Endpoint> eprBuilder;

	/**

	 * subscription actions.

	 */

	private List<SubscriptionAction> actions;

	@PostConstruct

	public void printList() {

		log.info(getActions());

	}

	/**

	 * {@inheritDoc}

	 *

	 * @throws ISSNException

	 *             could happen

	 * @see eu.dnetlib.enabling.hcm.sn.HCMSubscriber#subscribeAll()

	 */

	@Override

	public void subscribeAll() throws ISSNException {

		final W3CEndpointReference endpointReference = eprBuilder

				.getEndpointReference(getEndpoint());

		if (getActions() != null) {

			for (final SubscriptionAction action : getActions()) {

				log.info("dynamically subscribing to "

						+ action.getTopicExpression());

				snLocator.getService().subscribe(endpointReference,

						action.getTopicExpression(), 0);

			}

		}

	}

	public void setEndpoint(final Endpoint endpoint) {

		this.endpoint = endpoint;

	}

	public Endpoint getEndpoint() {

		return endpoint;

	}

	public void setEprBuilder(

			final EndpointReferenceBuilder<Endpoint> eprBuilder) {

		this.eprBuilder = eprBuilder;

	}

	public EndpointReferenceBuilder<Endpoint> getEprBuilder() {

		return eprBuilder;

	}

	public ServiceLocator<ISSNService> getSnLocator() {

		return snLocator;

	}

	public void setSnLocator(final ServiceLocator<ISSNService> snLocator) {

		this.snLocator = snLocator;

	}

	public List<SubscriptionAction> getActions() {

		return actions;

	}

	@Required

	public void setActions(final List<SubscriptionAction> actions) {

		this.actions = actions;

	}

}

package eu.dnetlib.enabling.hcm;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import eu.dnetlib.enabling.hcm.rmi.HostingContextManagerService;

import eu.dnetlib.enabling.tools.AbstractBaseService;

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

/**

 * CNR HostingContextManagerService implementation. Will conflict with NKUA! yes this is ok.

 * 

 * @author marko

 * 

 */

public class HostingContextManagerServiceImpl extends AbstractBaseService implements HostingContextManagerService {

	/**

	 * logger.

	 */

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

	/**

	 * notification handler.

	 */

	private NotificationHandler notificationHandler; // NOPMD

	@Override

	public void notify(String subscrId, String topic, String isId, String message) {

		if (log.isDebugEnabled()) {

			log.debug("---- service got notification ----");

			log.debug("subscrId: " + subscrId);

			log.debug("topic " + topic);

			log.debug("isId " + isId);

			log.debug("msg: " + message);

			log.debug("____ now processing the notification ____");

		}

		getNotificationHandler().notified(subscrId, topic, isId, message);

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.enabling.tools.AbstractBaseService#start()

	 */

	@Override

	public void start() {

		log.info("staring hosting context manager");

	}

	public NotificationHandler getNotificationHandler() {

		return notificationHandler;

	}

	@Required

	public void setNotificationHandler(NotificationHandler notificationHandler) {

		this.notificationHandler = notificationHandler;

	}

}

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

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

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

	xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

	xmlns:util="http://www.springframework.org/schema/util" xmlns:template="http://dnetlib.eu/springbeans/template"

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

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

		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.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.xsd">

	<!--  beans -->

	<bean id="hcmService"

		class="eu.dnetlib.enabling.hcm.HostingContextManagerServiceImpl"

		init-method="start" destroy-method="stop"  

		p:notificationHandler-ref="hcmNotificationHandler"/>

	<bean id="hcmNotificationHandler" class="eu.dnetlib.enabling.tools.blackboard.NotificationHandlerChainImpl"

		p:handlers-ref="dynamicSubscriptionActions">

		<property name="handlerExecutor">

			<bean class="org.springframework.core.task.SyncTaskExecutor" />

		</property>

	</bean>

	<bean id="dynamicSubscriptionActions"

		class="eu.dnetlib.enabling.hcm.sn.HCMSubscriptionListFactory" />

	<bean id="hcmSubscriber" class="eu.dnetlib.enabling.hcm.sn.HCMSubscriberImpl"

		p:endpoint-ref="hcmServiceEndpoint" p:snLocator-ref="snLocator" 

		p:actions-ref="dynamicSubscriptionActions" />

	<bean t:id="hcmJobSchedulerAccessor"

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

		p:scheduler-ref="jobScheduler">

		<property name="triggers">

			<list>

				<bean id="hcmSubscriptionTrigger"

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

					p:startDelay="6000" p:repeatCount="0">

					<property name="jobDetail">

						<bean id="hcmSubscriptionJobDetails"

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

							p:targetObject-ref="hcmSubscriber" p:targetMethod="subscribeAll" />

					</property>

				</bean>

			</list>

		</property>

	</bean>				

	<!-- endpoints -->

	<jaxws:endpoint id="hcmServiceEndpoint" implementor="#hcmService"

		implementorClass="eu.dnetlib.enabling.hcm.rmi.HostingContextManagerService"

		address="/hcm" />

	<template:instance name="serviceRegistrationManager"

		t:serviceRegistrationManagerClass="eu.dnetlib.enabling.tools.registration.ValidatingServiceRegistrationManagerImpl"

		t:name="hcmServiceRegistrationManager" t:service="hcmService"

		t:endpoint="hcmServiceEndpoint" t:jobScheduler="jobScheduler" />

</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-enabling-hcm-service</artifactId>

	<packaging>jar</packaging>

	<version>1.0.0</version>

	<scm>

		<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet40/modules/cnr-enabling-hcm-service/tags/cnr-enabling-hcm-service-1.0.0</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

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

			<version>[1.0.0, 2.0.0)</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-enabling-hcm-service/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-enabling-hcm-service"}

package eu.dnetlib.enabling.hcm.sn;

import java.util.List;

import org.springframework.beans.factory.FactoryBean;

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

import eu.dnetlib.enabling.actions.SubscriptionAction;

/**

 * This class acts as a simple registry of msro subscription actions.

 * 

 * <p>

 * Subscription actions are autodetected using spring autowiring from the current application context and are available for the manager for

 * handling subscriptions and delivering notification to particular code interested in those notifications.

 * </p>

 * 

 * @author marko

 * 

 */

@SuppressWarnings("rawtypes")

public class HCMSubscriptionListFactory implements FactoryBean {

	/**

	 * actions. Spring injects all the declared SubscriptionActions here.

	 */

	@Autowired(required = false)

	private List<SubscriptionAction> actions;

	public List<SubscriptionAction> getActions() {

		return actions;

	}

	public void setActions(final List<SubscriptionAction> actions) {

		this.actions = actions;

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see org.springframework.beans.factory.FactoryBean#getObject()

	 */

	@Override

	public Object getObject() {

		return getActions();

	}

	@Override

	public Class<?> getObjectType() {

		return null;

	}

	@Override

	public boolean isSingleton() {

		return false;

	}

}

package eu.dnetlib.enabling.hcm.sn;

import eu.dnetlib.enabling.is.sn.rmi.ISSNException;

/**

 * This component takes care of subscribing the MSRO service to interesting events.

 * 

 * @author marko

 *

 */

public interface HCMSubscriber {

	/**

	 * performs the subscription.

	 * @throws ISSNException could happen

	 */

	void subscribeAll() throws ISSNException;

}

package eu.dnetlib.enabling.hcm.sn;

import java.util.List;

import javax.annotation.PostConstruct;

import javax.annotation.Resource;

import javax.xml.ws.Endpoint;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import eu.dnetlib.enabling.actions.SubscriptionAction;

import eu.dnetlib.enabling.is.sn.rmi.ISSNException;

import eu.dnetlib.enabling.is.sn.rmi.ISSNService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.soap.EndpointReferenceBuilder;

/**

 * This component takes care of subscribing the SubscriptionAction(s) to interesting events.

 * 

 * @author claudio

 * 

 */

public class HCMSubscriberImpl implements HCMSubscriber {

	/**

	 * logger.

	 */

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

	/**

	 * notification endpoint (normally the msro service).

	 */

	private Endpoint endpoint;

	/**

	 * service locator.

	 */

	private UniqueServiceLocator serviceLocator;

	/**

	 * injected EPR builder.

	 */

	@Resource(name = "jaxwsEndpointReferenceBuilder")

	private EndpointReferenceBuilder<Endpoint> eprBuilder;

	/**

	 * subscription actions.

	 */

	private List<SubscriptionAction> actions;

	@PostConstruct

	public void printList() {

		log.info(getActions());

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @throws ISSNException

	 *             could happen

	 * @see eu.dnetlib.enabling.hcm.sn.HCMSubscriber#subscribeAll()

	 */

	@Override

	public void subscribeAll() throws ISSNException {

		final W3CEndpointReference endpointReference = eprBuilder

				.getEndpointReference(getEndpoint());

		if (getActions() != null) {

			for (final SubscriptionAction action : getActions()) {

				log.info("dynamically subscribing to "

						+ action.getTopicExpression());

				serviceLocator.getService(ISSNService.class, true).subscribe(endpointReference,

						action.getTopicExpression(), 0);

			}

		}

	}

	public void setEndpoint(final Endpoint endpoint) {

		this.endpoint = endpoint;

	}

	public Endpoint getEndpoint() {

		return endpoint;

	}

	public void setEprBuilder(

			final EndpointReferenceBuilder<Endpoint> eprBuilder) {

		this.eprBuilder = eprBuilder;

	}

	public EndpointReferenceBuilder<Endpoint> getEprBuilder() {

		return eprBuilder;

	}

	public List<SubscriptionAction> getActions() {

		return actions;

	}

	@Required

	public void setActions(final List<SubscriptionAction> actions) {

		this.actions = actions;

	}

	public UniqueServiceLocator getServiceLocator() {

		return serviceLocator;

	}

	@Required

	public void setServiceLocator(final UniqueServiceLocator serviceLocator) {

		this.serviceLocator = serviceLocator;

	}

}

package eu.dnetlib.enabling.hcm;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import eu.dnetlib.enabling.hcm.rmi.HostingContextManagerService;

import eu.dnetlib.enabling.tools.AbstractBaseService;

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

/**

 * CNR HostingContextManagerService implementation. Will conflict with NKUA! yes this is ok.

 * 

 * @author marko

 * 

 */

public class HostingContextManagerServiceImpl extends AbstractBaseService implements HostingContextManagerService {

	/**

	 * logger.

	 */

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

	/**

	 * notification handler.

	 */

	private NotificationHandler notificationHandler; // NOPMD

	@Override

	public void notify(String subscrId, String topic, String isId, String message) {

		if (log.isDebugEnabled()) {

			log.debug("---- service got notification ----");

			log.debug("subscrId: " + subscrId);

			log.debug("topic " + topic);

			log.debug("isId " + isId);

			log.debug("msg: " + message);

			log.debug("____ now processing the notification ____");

		}

		getNotificationHandler().notified(subscrId, topic, isId, message);

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.enabling.tools.AbstractBaseService#start()

	 */

	@Override

	public void start() {

		log.info("staring hosting context manager");

	}

	public NotificationHandler getNotificationHandler() {

		return notificationHandler;

	}

	@Required

	public void setNotificationHandler(NotificationHandler notificationHandler) {

		this.notificationHandler = notificationHandler;

	}

}

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

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

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

	xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

	xmlns:util="http://www.springframework.org/schema/util" xmlns:template="http://dnetlib.eu/springbeans/template"

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

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

		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.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.xsd">

	<!--  beans -->

	<bean id="hcmService"

		class="eu.dnetlib.enabling.hcm.HostingContextManagerServiceImpl"

		init-method="start" destroy-method="stop"  

		p:notificationHandler-ref="hcmNotificationHandler"/>

	<bean id="hcmNotificationHandler" class="eu.dnetlib.enabling.tools.blackboard.NotificationHandlerChainImpl"

		p:handlers-ref="dynamicSubscriptionActions">

		<property name="handlerExecutor">

			<bean class="org.springframework.core.task.SyncTaskExecutor" />

		</property>

	</bean>

	<bean id="dynamicSubscriptionActions"

		class="eu.dnetlib.enabling.hcm.sn.HCMSubscriptionListFactory" />

	<bean id="hcmSubscriber" class="eu.dnetlib.enabling.hcm.sn.HCMSubscriberImpl"

		p:endpoint-ref="hcmServiceEndpoint" p:serviceLocator-ref="uniqueServiceLocator" 

		p:actions-ref="dynamicSubscriptionActions" />

	<bean t:id="hcmJobSchedulerAccessor"

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

		p:scheduler-ref="jobScheduler">

		<property name="triggers">

			<list>

				<bean id="hcmSubscriptionTrigger"

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

					p:startDelay="6000" p:repeatCount="0">

					<property name="jobDetail">

						<bean id="hcmSubscriptionJobDetails"

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

							p:targetObject-ref="hcmSubscriber" p:targetMethod="subscribeAll" />

					</property>

				</bean>

			</list>

		</property>

	</bean>				

	<!-- endpoints -->

	<jaxws:endpoint id="hcmServiceEndpoint" implementor="#hcmService"

		implementorClass="eu.dnetlib.enabling.hcm.rmi.HostingContextManagerService"

		address="/hcm" />

	<template:instance name="serviceRegistrationManager"

		t:serviceRegistrationManagerClass="eu.dnetlib.enabling.tools.registration.ValidatingServiceRegistrationManagerImpl"

		t:name="hcmServiceRegistrationManager" t:service="hcmService"

		t:endpoint="hcmServiceEndpoint" t:jobScheduler="jobScheduler" />

</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-enabling-hcm-service</artifactId>

	<packaging>jar</packaging>

	<version>2.0.0</version>

	<scm>

		<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet40/modules/cnr-enabling-hcm-service/tags/cnr-enabling-hcm-service-2.0.0</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

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

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

		</dependency>

	</dependencies>

</project>