D-Net

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

<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">

  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_8" inherit-compiler-output="false">

    <output url="file://$MODULE_DIR$/target/classes" />

    <output-test url="file://$MODULE_DIR$/target/test-classes" />

    <content url="file://$MODULE_DIR$">

      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />

      <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />

      <excludeFolder url="file://$MODULE_DIR$/target" />

    </content>

    <orderEntry type="inheritedJdk" />

    <orderEntry type="sourceFolder" forTests="false" />

    <orderEntry type="library" name="Maven: eu.dnetlib:cnr-notifications-common:2.1.1-SNAPSHOT" level="project" />

    <orderEntry type="module" module-name="cnr-service-common" />

    <orderEntry type="library" name="Maven: org.antlr:stringtemplate:3.2" level="project" />

    <orderEntry type="library" name="Maven: org.antlr:antlr:2.7.7" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-tx:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-beans:4.2.5.RELEASE" level="project" />

    <orderEntry type="module" module-name="cnr-misc-utils" />

    <orderEntry type="library" name="Maven: commons-lang:commons-lang:2.6" level="project" />

    <orderEntry type="library" name="Maven: commons-codec:commons-codec:1.9" level="project" />

    <orderEntry type="library" name="Maven: dom4j:dom4j:1.6.1" level="project" />

    <orderEntry type="library" name="Maven: xml-apis:xml-apis:1.0.b2" level="project" />

    <orderEntry type="library" name="Maven: jaxen:jaxen:1.1.6" level="project" />

    <orderEntry type="library" name="Maven: saxonica:saxon:9.1.0.8" level="project" />

    <orderEntry type="library" name="Maven: saxonica:saxon-dom:9.1.0.8" level="project" />

    <orderEntry type="library" name="Maven: jgrapht:jgrapht:0.7.2" level="project" />

    <orderEntry type="library" name="Maven: net.sf.ehcache:ehcache:2.8.0" level="project" />

    <orderEntry type="library" name="Maven: com.google.guava:guava:18.0" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-test:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: eu.dnetlib:cnr-service-utils:1.0.2-SNAPSHOT" level="project" />

    <orderEntry type="library" name="Maven: apache:oro:2.0.8" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-frontend-jaxws:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: xml-resolver:xml-resolver:1.2" level="project" />

    <orderEntry type="library" name="Maven: org.ow2.asm:asm:5.0.4" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-bindings-soap:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-wsdl:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: wsdl4j:wsdl4j:1.6.3" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-databinding-jaxb:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: com.sun.xml.bind:jaxb-impl:2.2.11" level="project" />

    <orderEntry type="library" name="Maven: com.sun.xml.bind:jaxb-core:2.2.11" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-bindings-xml:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-frontend-simple:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-ws-addr:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-ws-policy:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: org.apache.neethi:neethi:3.0.3" level="project" />

    <orderEntry type="library" name="Maven: eu.dnetlib:cnr-rmi-api:2.6.1-SNAPSHOT" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-core:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: org.codehaus.woodstox:woodstox-core-asl:4.4.1" level="project" />

    <orderEntry type="library" name="Maven: org.codehaus.woodstox:stax2-api:3.1.4" level="project" />

    <orderEntry type="library" name="Maven: org.apache.ws.xmlschema:xmlschema-core:2.2.1" level="project" />

    <orderEntry type="module" module-name="cnr-spring-utils" />

    <orderEntry type="library" name="Maven: commons-io:commons-io:2.4" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-aop:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: aopalliance:aopalliance:1.0" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-web:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-webmvc:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: jparsec:jparsec:2.0" level="project" />

    <orderEntry type="library" name="Maven: runcc:runcc:0.7" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-context-support:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-context:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-expression:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: org.springframework:spring-core:4.2.5.RELEASE" level="project" />

    <orderEntry type="library" name="Maven: commons-logging:commons-logging:1.2" level="project" />

    <orderEntry type="library" name="Maven: org.quartz-scheduler:quartz:2.2.2" level="project" />

    <orderEntry type="library" name="Maven: c3p0:c3p0:0.9.1.1" level="project" />

    <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.7" level="project" />

    <orderEntry type="library" name="Maven: log4j:log4j:1.2.17" level="project" />

  </component>

</module>

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

package eu.dnetlib.enabling.hcm.sn;

import java.util.List;

import com.google.common.collect.Lists;

import eu.dnetlib.enabling.actions.SubscriptionAction;

import org.springframework.beans.factory.FactoryBean;

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

/**

 * 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<List<SubscriptionAction>> {

	/**

	 * actions. Spring injects all the declared SubscriptionActions here.

	 */

	@Autowired(required = false)

	private List<SubscriptionAction> actions = Lists.newArrayList();

	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 List<SubscriptionAction> getObject() {

		return getActions();

	}

	@Override

	public Class<List> getObjectType() {

		return List.class;

	}

	@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.SimpleTriggerFactoryBean"

					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>dnet45-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</version>

	<scm>

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

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

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

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

		</dependency>

	</dependencies>

</project>