/ - Diff - D-Net - D-Net project tracking tool

     package eu.dnetlib.enabling.is.sn;
     public class NotificationMessage {
     	private String serviceId;
     	private String subscriptionId;
     	private String topic;
     	private String isId;
     	private String message;
     	public NotificationMessage() {}
     	public NotificationMessage(final String serviceId, final String subscriptionId, final String topic, final String isId, final String message) {
     		this.serviceId = serviceId;
     		this.subscriptionId = subscriptionId;
     		this.topic = topic;
     		this.isId = isId;
     		this.message = message;
+    	}
     	public String getServiceId() {
     		return serviceId;
+    	}
     	public void setServiceId(final String serviceId) {
     		this.serviceId = serviceId;
+    	}
     	public String getSubscriptionId() {
     		return subscriptionId;
+    	}
     	public void setSubscriptionId(final String subscriptionId) {
     		this.subscriptionId = subscriptionId;
+    	}
     	public String getTopic() {
     		return topic;
+    	}
     	public void setTopic(final String topic) {
     		this.topic = topic;
+    	}
     	public String getIsId() {
     		return isId;
+    	}
     	public void setIsId(final String isId) {
     		this.isId = isId;
+    	}
     	public String getMessage() {
     		return message;
+    	}
     	public void setMessage(final String message) {
     		this.message = message;
+    	}
+    }

     	private DatabaseUtils dbUtils;
     	private NotificationDispatcher dispatcher;
     	private boolean running = false;
     	private Connection conn = null;
     	private String query = "";
-...
     						final Map<String, Object> mapTest = obtainMapFromJson((String) map.get(operation == Operation.DELETE ? "old" : "new"));
     						if (compareMaps(mapCond, mapTest)) {
     							log.info("SENDING NOTIFICATIN TO " + map.get("subscriber"));
     							// TODO
     							log.info("SENDING NOTIFICATIN TO " + map.get("service_id"));
     							final NotificationMessage message = new NotificationMessage();
     							message.setSubscriptionId((String) map.get("subscr_id"));
     							message.setIsId("XXXX");
     							message.setMessage((String) map.get(operation == Operation.DELETE ? "old" : "new"));
     							message.setServiceId((String) map.get("service_id"));
     							message.setTopic(map.get("operation") + "/" + map.get("tbl"));
     							dispatcher.sendNotification(message);
+    						}
+    					}
+    				}
-...
     	public void setDbUtils(final DatabaseUtils dbUtils) {
     		this.dbUtils = dbUtils;
+    	}
     	public NotificationDispatcher getDispatcher() {
     		return dispatcher;
+    	}
     	@Required
     	public void setDispatcher(final NotificationDispatcher dispatcher) {
     		this.dispatcher = dispatcher;
+    	}
+    }

     package eu.dnetlib.enabling.is.sn;
     import java.util.concurrent.BlockingQueue;
     import java.util.concurrent.LinkedBlockingQueue;
     import javax.annotation.Resource;
     import org.apache.commons.logging.Log;
     import org.apache.commons.logging.LogFactory;
     import eu.dnetlib.common.rmi.BaseService;
     import eu.dnetlib.enabling.locators.UniqueServiceLocator;
     public class NotificationDispatcher {
     	@Resource
     	private UniqueServiceLocator serviceLocator;
     	private final BlockingQueue<NotificationMessage> queue = new LinkedBlockingQueue<NotificationMessage>();
     	private static final Log log = LogFactory.getLog(NotificationDispatcher.class);
     	public void processQueue() {
     		while (true) {
     			final NotificationMessage message = queue.poll();
     			if (message == null) {
     				return;
     			} else {
     				try {
     					log.info("Invoking notify method...");
     					final String serviceId = message.getServiceId();
     					final BaseService service = serviceLocator.getService(BaseService.class, serviceId);
     					service.notify(message.getSubscriptionId(), message.getTopic(), message.getIsId(), message.getMessage());
     					log.info("...done");
     				} catch (Throwable e) {
     					log.error("Error notifying service", e);
     					return;
+    				}
+    			}
+    		}
+    	}
     	public void sendNotification(final NotificationMessage message) {
     		queue.add(message);
+    	}
+    }

     	<!-- Notification Listener -->
     	<bean id="isNotificationListener" class="eu.dnetlib.enabling.is.sn.NotificationListener"
     		p:dbUtils-ref="isDatabaseUtils"
     		p:dbUtils-ref="isDatabaseUtils" p:dispatcher-ref="isNotificationDispatcher"
     		init-method="init" destroy-method="destroy"/>
     	<bean id="isNotificationDispatcher" class="eu.dnetlib.enabling.is.sn.NotificationDispatcher" />
     	<bean t:id="isJobSchedulerAccessor"
     		class="org.springframework.scheduling.quartz.SchedulerAccessorBean"
     		p:scheduler-ref="jobScheduler">
-...
     							p:targetObject-ref="isNotificationListener" p:targetMethod="verify" />
     					</property>
     				</bean>
     				<bean class="org.springframework.scheduling.quartz.SimpleTriggerBean"
     					p:startDelay="${dnet.is.sn.dispatcher.startDelay}" p:repeatInterval="${dnet.is.sn.dispatcher.repeatInterval}">
     					<property name="jobDetail">
     						<bean
     							class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"
     							p:targetObject-ref="isNotificationDispatcher" p:targetMethod="processQueue" />
     					</property>
     				</bean>
     			</list>
     		</property>
     	</bean>

     dnet.is.database.username       = dnet
     dnet.is.database.password       = dnetPwd
     dnet.is.database.resetAtStartup = true
     dnet.is.sn.listener.startDelay     = 10000
     dnet.is.sn.listener.repeatInterval = 5000
     dnet.is.sn.listener.startDelay     = 10000
     dnet.is.sn.listener.repeatInterval = 5000
     dnet.is.sn.dispatcher.startDelay     = 20000
     dnet.is.sn.dispatcher.repeatInterval = 5000

     select
     	n.tbl,
     	n.operation,
     	n.date,
     	n.new,
     	n.old,
     	s.subscriber,
     	s.condition
     	n.tbl        as tbl,
     	n.operation  as operation,
     	n.new        as new,
     	n.old        as old,
     	s.id         as subscr_id
     	s.subscriber as service_id,
     	s.condition  as condition
     from
     	notifications n left outer join subscriptions s on (n.tbl = s.tbl and n.operation = s.operation)

D-Net