SDN-R update common

[ccsdk/features.git] / sdnr / wt / devicemanager / provider / src / main / java / org / onap / ccsdk / features / sdnr / wt / devicemanager / base / onfcore / NotificationWorker.java

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 (file)
index 0c3014a..0000000
--- 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;
-                               }
-                       }
-               }
-       }
-
-
-
-}