From: Boslet, Cory <cory.boslet@att.com>
Date: Thu, 25 Jun 2020 12:49:10 +0000 (-0400)
Subject: Loop over max clients to fix topic not getting
X-Git-Tag: 1.7.1~93^2
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F49%2F109549%2F1;p=so.git

Loop over max clients to fix topic not getting

Loop over max clients to fix topic not getting subscribed.

Issue-ID: SO-3007
Signed-off-by: Benjamin, Max (mb388a) <mb388a@att.com>
Change-Id: I8a63fed874946528d1318bfa2e10e663c688444b
---

diff --git a/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/delete/DeleteInventoryService.java b/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/delete/DeleteInventoryService.java
index b104c3310c..4d8c74dbfe 100644
--- a/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/delete/DeleteInventoryService.java
+++ b/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/delete/DeleteInventoryService.java
@@ -21,7 +21,6 @@
 package org.onap.so.adapters.inventory.delete;
 
 import javax.annotation.PostConstruct;
-import org.camunda.bpm.client.ExternalTaskClient;
 import org.onap.so.utils.ExternalTaskServiceUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Profile;
@@ -43,10 +42,11 @@ public class DeleteInventoryService {
 
     @PostConstruct
     public void auditAAIInventory() throws Exception {
-        ExternalTaskClient client = externalTaskServiceUtils.createExternalTaskClient();
-        client.subscribe("InventoryDelete")
-                .lockDuration(Long.parseLong(env.getProperty("mso.audit.lock-time", "60000")))
-                .handler(deleteInventory::executeExternalTask).open();
+        for (int i = 0; i < externalTaskServiceUtils.getMaxClients(); i++) {
+            externalTaskServiceUtils.createExternalTaskClient().subscribe("InventoryDelete")
+                    .lockDuration(Long.parseLong(env.getProperty("mso.audit.lock-time", "60000")))
+                    .handler(deleteInventory::executeExternalTask).open();
+        }
     }
 
 }