diff options
author | ayalaben <Ayala.Benzvi@Amdocs.Com> | 2018-05-07 14:01:00 +0300 |
---|---|---|
committer | ayalaben <ayala.benzvi@amdocs.com> | 2018-05-07 14:01:58 +0300 |
commit | 70a3309f5e3e531981691e08d74cf89fa832c2a4 (patch) | |
tree | b42df01b4bab601909bc3396b8c3e5d971ffa577 /openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java | |
parent | 310804a209a059c87cf50a08e7df9cc4a1121e3c (diff) |
notify catalog on items action
Change-Id: I11aa241c0c74c1a426dc1eee30ec7adb09abdca4
Issue-ID: SDC-1257
Signed-off-by: ayalaben <ayala.benzvi@amdocs.com>
Diffstat (limited to 'openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java')
-rw-r--r-- | openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/CatalogNotifier.java | 45 |
1 files changed, 25 insertions, 20 deletions
diff --git a/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/CatalogNotifier.java b/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/CatalogNotifier.java index 48a4f9c3b6..f19de3d04a 100644 --- a/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/CatalogNotifier.java +++ b/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/CatalogNotifier.java @@ -60,6 +60,7 @@ public class CatalogNotifier { private static String notifyCatalogUrl; private static ScheduledExecutorService executor = Executors.newScheduledThreadPool(1); + private static boolean executeNotificationFlag = true; static { @@ -72,38 +73,42 @@ public class CatalogNotifier { try { configurationMap = readFromFile(configurationYamlFile, reader); + Object protocol = configurationMap.get(PROTOCOL_KEY); + Object host = configurationMap.get(HOST_KEY); + Object port = configurationMap.get(PORT_KEY); - } catch (IOException e) { - throw new RuntimeException("Could not read configuration file configuration.yaml"); - } - - Object protocol = configurationMap.get(PROTOCOL_KEY); - Object host = configurationMap.get(HOST_KEY); - Object port = configurationMap.get(PORT_KEY); + if (protocol == null || host == null || port == null) { + LOGGER.error("Could not read configuration file configuration.yaml"); + executeNotificationFlag = false; + } - if (protocol == null || host == null || port == null) { - throw new RuntimeException("Could not read configuration file configuration.yaml"); - } + if (configurationMap.get(URL_KEY) != null) { + String urlFormat = String.valueOf(configurationMap.get(URL_KEY)); + notifyCatalogUrl = + String.format(urlFormat, String.valueOf(protocol), String.valueOf(host), String.valueOf(port)); - if (configurationMap.get(URL_KEY) != null) { - String urlFormat = String.valueOf(configurationMap.get(URL_KEY)); - notifyCatalogUrl = - String.format(urlFormat, String.valueOf(protocol), String.valueOf(host), String.valueOf(port)); + } else { + notifyCatalogUrl = String.format(URL_DEFAULT_FORMAT, String.valueOf(protocol), String.valueOf(host), + String.valueOf(port)); + } - } else { - notifyCatalogUrl = String.format(URL_DEFAULT_FORMAT, String.valueOf(protocol), String.valueOf(host), - String.valueOf(port)); + } catch (Exception e) { + LOGGER.error("Could not read configuration file configuration.yaml"); + executeNotificationFlag = false; } } public void execute(Collection<String> itemIds, ItemAction action, int numOfRetries) { - String userId = SessionContextProviderFactory.getInstance().createInterface().get().getUser().getUserId(); + if (executeNotificationFlag) { - Callable callable = createCallable(JsonUtil.object2Json(itemIds), action, numOfRetries, userId); + String userId = SessionContextProviderFactory.getInstance().createInterface().get().getUser().getUserId(); - executor.submit(callable); + Callable callable = createCallable(JsonUtil.object2Json(itemIds), action, numOfRetries, userId); + + executor.submit(callable); + } } |