D-Net

package eu.dnetlib.clients.ws;

import org.apache.log4j.Logger;

import eu.dnetlib.api.DriverService;

import eu.dnetlib.domain.ServiceIdentity;

import eu.dnetlib.domain.enabling.Notification;

public abstract class BaseDriverWebService<S extends DriverService> implements

		DriverWebService<S> {

	private static Logger logger = Logger.getLogger(BaseDriverWebService.class);

	protected S service = null;

	public void setService(S service) {

		this.service = service;

	}

	@Override

	public final String identify() {

		ServiceIdentity identity = service.identify();

		if (identity != null)

			return service.identify().toString();

		else

			return null;

	}

	@Override

	public final void notify(String subscriptionId, String topic, String isId,

			String message) {

		logger.debug("Notification received: " + topic + ", message: "

				+ message);

		try {

			Notification notification = new Notification(subscriptionId,

					message, topic, isId);

			service.notify(notification);

		} catch (Exception e) {

			logger.error("Error creating notification", e);

		}

	}

	@Override

	public void start() {

		throw new UnsupportedOperationException();

	}

}