diff options
| author |   Steve Smokowski <ss835w@att.com> | 2019-04-08 16:44:38 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2019-04-08 16:44:38 +0000 |
| commit | 840e68bac1cb39d536a46ad98193466eb320733a (patch) | |
| tree | 4f1c468127ce4429b79fa1dad06047608e41b6b6 /adapters/mso-openstack-adapters | |
| parent | e1f8849de4ca1395d33f4a5275f597cbfca25e90 (diff) | |
| parent | bdaffefc010f006019607a689f553ac4184888ee (diff) | |
Merge "Fix POM to allow HTTP long polling to work"
Diffstat (limited to 'adapters/mso-openstack-adapters')
2 files changed, 3 insertions, 3 deletions
diff --git a/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditStackService.java b/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditStackService.java index 1e16c2a016..ed29a1c47d 100644 --- a/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditStackService.java +++ b/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditStackService.java @@ -63,7 +63,7 @@ public class AuditStackService { auth); ExternalTaskClient client = ExternalTaskClient.create() .baseUrl(env.getRequiredProperty("mso.workflow.endpoint")).maxTasks(1).addInterceptor(interceptor) - .asyncResponseTimeout(120000).build(); + .asyncResponseTimeout(120000).backoffStrategy(new ExponentialBackoffStrategy(0, 0, 0)).build(); client.subscribe("InventoryAddAudit").lockDuration(60000) .handler(auditCreateStack::executeExternalTask).open(); } @@ -80,7 +80,7 @@ public class AuditStackService { auth); ExternalTaskClient client = ExternalTaskClient.create() .baseUrl(env.getRequiredProperty("mso.workflow.endpoint")).maxTasks(1).addInterceptor(interceptor) - .asyncResponseTimeout(120000).build(); + .asyncResponseTimeout(120000).backoffStrategy(new ExponentialBackoffStrategy(0,0,0)).build(); client.subscribe("InventoryDeleteAudit").lockDuration(60000) .handler(auditDeleteStack::executeExternalTask).open(); } diff --git a/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/create/CreateInventoryService.java b/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/create/CreateInventoryService.java index b2eadaf3c8..58d8a4cd55 100644 --- a/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/create/CreateInventoryService.java +++ b/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/create/CreateInventoryService.java @@ -60,7 +60,7 @@ public class CreateInventoryService { auth); ExternalTaskClient client = ExternalTaskClient.create() .baseUrl(env.getRequiredProperty("mso.workflow.endpoint")).maxTasks(1).addInterceptor(interceptor) - .asyncResponseTimeout(120000).backoffStrategy(new ExponentialBackoffStrategy(10000, 2, 120000)).build(); + .asyncResponseTimeout(120000).backoffStrategy(new ExponentialBackoffStrategy(0, 0, 0)).build(); client.subscribe("InventoryCreate").lockDuration(60000) .handler(createInventory::executeExternalTask).open(); } |