Fix POM to allow HTTP long polling to work 29/84529/1
authorBenjamin, Max (mb388a) <mb388a@us.att.com>
Mon, 8 Apr 2019 13:31:59 +0000 (09:31 -0400)
committerBenjamin, Max (mb388a) <mb388a@us.att.com>
Mon, 8 Apr 2019 13:32:31 +0000 (09:32 -0400)
Fix POM to allow HTTP long polling to work on camunda

Change-Id: I5f9da8b88ad8b14a1ef596f65b95d941c130e794
Issue-ID: SO-1758
Signed-off-by: Benjamin, Max (mb388a) <mb388a@us.att.com>
adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditStackService.java
adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/inventory/create/CreateInventoryService.java
bpmn/mso-infrastructure-bpmn/pom.xml

index 1e16c2a..ed29a1c 100644 (file)
@@ -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();
        }
index b2eadaf..58d8a4c 100644 (file)
@@ -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();
        }
index 6f0b1f6..2abea6e 100644 (file)
                        <artifactId>camunda-bpm-spring-boot-starter</artifactId>
                        <version>${camunda.springboot.version}</version>
                </dependency>
-               <dependency>
-                       <groupId>org.camunda.bpm.springboot</groupId>
-                       <artifactId>camunda-bpm-spring-boot-starter-webapp</artifactId>
-                       <version>${camunda.springboot.version}</version>
-               </dependency>
                <dependency>
                        <groupId>org.camunda.bpm.springboot</groupId>
                        <artifactId>camunda-bpm-spring-boot-starter-rest</artifactId>
                <dependency>
                        <groupId>org.camunda.bpm.springboot</groupId>
                        <artifactId>camunda-bpm-spring-boot-starter-webapp</artifactId>
-                       <version>2.3.0</version>
+                       <version>${camunda.springboot.version}</version>
+                       <exclusions>
+                               <exclusion>
+                                       <groupId>org.camunda.bpmn</groupId>
+                                       <artifactId>camunda-engine-rest-core</artifactId>
+                               </exclusion>
+                       </exclusions>
                </dependency>
                <dependency>
                        <groupId>org.springframework.boot</groupId>