X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=sdnr%2Fwt%2Fdevicemanager%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fccsdk%2Ffeatures%2Fsdnr%2Fwt%2Fdevicemanager%2Fbase%2Fonfcore%2FNotificationWorker.java;fp=sdnr%2Fwt%2Fdevicemanager%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fccsdk%2Ffeatures%2Fsdnr%2Fwt%2Fdevicemanager%2Fbase%2Fonfcore%2FNotificationWorker.java;h=0000000000000000000000000000000000000000;hb=d1981f7e68272cdc5618139a363b80806c2aa77c;hp=0c3014a0d6d51310e4719bba8b0f3b86bb13b230;hpb=032ce4ec7c3d7ac138555dfe980ca53ebbf39f01;p=ccsdk%2Ffeatures.git

diff --git a/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/base/onfcore/NotificationWorker.java b/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/base/onfcore/NotificationWorker.java
deleted file mode 100644
index 0c3014a0d..000000000
--- a/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/base/onfcore/NotificationWorker.java
+++ /dev/null
@@ -1,89 +0,0 @@
-/*******************************************************************************
- * ============LICENSE_START========================================================================
- * ONAP : ccsdk feature sdnr wt
- * =================================================================================================
- * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
- * =================================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
- * in compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software distributed under the License
- * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
- * or implied. See the License for the specific language governing permissions and limitations under
- * the License.
- * ============LICENSE_END==========================================================================
- ******************************************************************************/
-package org.onap.ccsdk.features.sdnr.wt.devicemanager.base.onfcore;
-
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.LinkedBlockingQueue;
-
-/**
- * Provide a thread that is receiving and process notifications.
- * @param <T> represents the object that is provided with a notification and
- * forwarded to the NotificationActor<T>.
- *
- * @author herbert
- */
-
-public class NotificationWorker<T> implements AutoCloseable {
-
-	private final BlockingQueue<T> workQueue;
-	private final ExecutorService service;
-	private final NotificationActor<T> actor;
-
-	public NotificationWorker(int numWorkers, int workQueueSize, NotificationActor<T> actorObject) {
-		workQueue = new LinkedBlockingQueue<T>(workQueueSize);
-		service = Executors.newFixedThreadPool(numWorkers);
-		actor = actorObject;
-
-		for (int i=0; i < numWorkers; i++) {
-			service.submit(new Worker<T>(workQueue, actor));
-		}
-	}
-
-	public void put(T item) {
-		try {
-			workQueue.put(item);
-		} catch (InterruptedException ex) {
-			Thread.currentThread().interrupt();
-		}
-	}
-
-	@Override
-	public void close() throws Exception {
-		// TODO Auto-generated method stub
-	}
-
-	private static class Worker<T> implements Runnable {
-        private final BlockingQueue<T> workQueue;
-		private final NotificationActor<T> actor;
-
-
-        public Worker(BlockingQueue<T> workQueue, NotificationActor<T> actor) {
-            this.workQueue = workQueue;
-            this.actor = actor;
-        }
-
-		@Override
-		public void run() {
-			while (!Thread.currentThread().isInterrupted()) {
-				try {
-					T item = workQueue.take();
-					actor.notificationActor(item);
-					// Process item
-				} catch (InterruptedException ex) {
-					Thread.currentThread().interrupt();
-					break;
-				}
-			}
-		}
-	}
-
-
-
-}