aboutsummaryrefslogtreecommitdiffstats
path: root/ecomp-sdk-app/src/main/java/org/openecomp/policy/admin/PAPNotificationBroadcaster.java
diff options
context:
space:
mode:
authorITSERVICES\rb7147 <rb7147@att.com>2017-04-25 11:46:00 -0400
committerITSERVICES\rb7147 <rb7147@att.com>2017-05-03 09:58:17 -0400
commite0addf5b588a1244f9679becd90999dfcb4c3a94 (patch)
tree1212772d6366730266ff0e093c874b07aa716c29 /ecomp-sdk-app/src/main/java/org/openecomp/policy/admin/PAPNotificationBroadcaster.java
parent39fb0f30472777e4b60d6a7ac8aa4eb9773961ff (diff)
Policy 1707 commit to LF
Change-Id: Ibe6f01d92f9a434c040abb05d5386e89d675ae65 Signed-off-by: ITSERVICES\rb7147 <rb7147@att.com>
Diffstat (limited to 'ecomp-sdk-app/src/main/java/org/openecomp/policy/admin/PAPNotificationBroadcaster.java')
-rw-r--r--ecomp-sdk-app/src/main/java/org/openecomp/policy/admin/PAPNotificationBroadcaster.java120
1 files changed, 0 insertions, 120 deletions
diff --git a/ecomp-sdk-app/src/main/java/org/openecomp/policy/admin/PAPNotificationBroadcaster.java b/ecomp-sdk-app/src/main/java/org/openecomp/policy/admin/PAPNotificationBroadcaster.java
deleted file mode 100644
index cff0828e2..000000000
--- a/ecomp-sdk-app/src/main/java/org/openecomp/policy/admin/PAPNotificationBroadcaster.java
+++ /dev/null
@@ -1,120 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ECOMP Policy Engine
- * ================================================================================
- * Copyright (C) 2017 AT&T 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.openecomp.policy.admin;
-
-
-import java.io.Serializable;
-import java.util.LinkedList;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-
-/**
- * Handle Notifications from the PAP that the PDP Groups have been changed.
- * We need a Server Push Broadcaster because there may be multiple Vaadin instances (i.e. Users) that need to be told when a change occurs.
- *
- * Initially we only update the entire set of PDPGroups in one shot.
- *
- * (Code copied from Book of Vaadin chapter on Server Push
- *
- */
-public class PAPNotificationBroadcaster implements Serializable {
- /**
- *
- */
- private static final long serialVersionUID = -2539940306348821754L;
-
-
- private static Logger logger = FlexLogger.getLogger(PAPNotificationBroadcaster.class);
-
-
- static ExecutorService executorService = Executors.newSingleThreadExecutor();
-
- /**
- * Interface used by all classes that need to be notified when PAP sends an update message.
- *
- *
- */
- public interface PAPNotificationBroadcastListener {
- void updateAllGroups();
- }
-
-
-
- /*
- * list of registered listeners
- */
- private static LinkedList<PAPNotificationBroadcastListener> listeners =
- new LinkedList<PAPNotificationBroadcastListener>();
-
- /**
- * Listener registers to hear about updates.
- * @param listener
- */
- public static synchronized void register(
- PAPNotificationBroadcastListener listener) {
- listeners.add(listener);
- }
-
-
- /**
- * Listener is going away.
- *
- * @param listener
- */
- public static synchronized void unregister(
- PAPNotificationBroadcastListener listener) {
- listeners.remove(listener);
- }
-
-
-
- /**
- * Tell all listeners about an update.
- *
- * @param message
- */
- public static synchronized void updateAllGroups() {
- for (final PAPNotificationBroadcastListener listener: listeners) {
- // Original code copied from example:
- // executorService.execute(new Runnable() {
- // @Override
- // public void run() {
- // The problem with this is that the execute starts a new Thread, but the thing we are calling (the listener.updateAllGroups)
- // happens in this case to ALSO create a new thread, and it locks up because the shared threadpool queue is already locked by this method.
- // On application shutdown that left us with a blocked thread, so the process never goes away.
- // Since the listener.updateAllGroups does ALL of its work inside a new Runnable thread, there should be no need for this method to also create a thread.
-
- /*
- * IMPORTANT:
- * All listeners MUST either execute with no possibility of blocking
- * OR must start their own threads to handle blocking and concurrent operations.
- */
- if (logger.isDebugEnabled()) {
- logger.debug("updateAllGroups");
- }
- listener.updateAllGroups();
- }
- }
-}