Merge pull request #13 from elasticio/flowcontrol

Upgrade to Sailor 3.1.0

Author: Igor Drobiazko

build.gradle

@@ -31,7 +31,7 @@ repositories {
 }
 
 dependencies {
-    compile "io.elastic:sailor-jvm:2.1.3-SNAPSHOT"
+    compile "io.elastic:sailor-jvm:3.1.0"
     compile "org.glassfish.jersey.core:jersey-client:2.25.1"
     compile "org.glassfish.jersey.media:jersey-media-json-processing:2.25.1"
 }

src/main/java/io/elastic/petstore/actions/CreatePet.java

@@ -1,8 +1,8 @@
 package io.elastic.petstore.actions;
 
 import io.elastic.api.ExecutionParameters;
+import io.elastic.api.Function;
 import io.elastic.api.Message;
-import io.elastic.api.Module;
 import io.elastic.petstore.HttpClientUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -13,7 +13,7 @@
 /**
  * Action to create a pet.
  */
-public class CreatePet implements Module {
+public class CreatePet implements Function {
     private static final Logger logger = LoggerFactory.getLogger(CreatePet.class);
 
     /**

src/main/java/io/elastic/petstore/triggers/GetPetsByStatus.java

@@ -1,8 +1,8 @@
 package io.elastic.petstore.triggers;
 
 import io.elastic.api.ExecutionParameters;
+import io.elastic.api.Function;
 import io.elastic.api.Message;
-import io.elastic.api.Module;
 import io.elastic.petstore.HttpClientUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -12,10 +12,11 @@
 import javax.json.JsonObject;
 import javax.json.JsonString;
 
+
 /**
  * Trigger to get pets by status.
  */
-public class GetPetsByStatus implements Module {
+public class GetPetsByStatus implements Function {
     private static final Logger logger = LoggerFactory.getLogger(GetPetsByStatus.class);
 
     /**

src/main/java/io/elastic/petstore/triggers/GetPetsByStatusJaxRs.java

@@ -1,8 +1,8 @@
 package io.elastic.petstore.triggers;
 
 import io.elastic.api.ExecutionParameters;
+import io.elastic.api.Function;
 import io.elastic.api.Message;
-import io.elastic.api.Module;
 import io.elastic.petstore.Constants;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -17,7 +17,7 @@
 /**
  * Trigger to get pets by status.
  */
-public class GetPetsByStatusJaxRs implements Module {
+public class GetPetsByStatusJaxRs implements Function {
     private static final Logger logger = LoggerFactory.getLogger(GetPetsByStatusJaxRs.class);
 
     /**