work with json variable

Author: saig0

payment/scr/main/resources/application.conf

@@ -0,0 +1,22 @@
+akka{ 
+
+  loglevel = "DEBUG"
+  loggers = ["akka.event.slf4j.Slf4jLogger"]  
+  event-handlers = ["akka.event.slf4j.Slf4jEventHandler"]
+
+  actor {
+    deployment {
+    
+      default {
+        router = "from-code"
+        nr-of-instances = 1
+      }
+      
+      parent/worker-1 {
+        router = round-robin-pool
+        nr-of-instances = 5
+      }
+      
+    }
+  }
+}

payment/scr/main/resources/logback.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+
+  <appender name="FILE" class="ch.qos.logback.core.FileAppender">
+    <file>log/default.log</file>
+    <encoder>
+      <pattern>[%date] [%level] [%thread] %logger{10} %msg%n</pattern>
+    </encoder>
+  </appender>
+
+  <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+    <encoder>
+      <pattern>[%date] [%level] [%thread] %logger{10} %msg%n</pattern>
+    </encoder>
+  </appender>
+
+  <!-- <logger name="ui"> <appender-ref ref="STDOUT" /> </logger> -->
+
+  <logger name="org.camunda" level="INFO" />
+
+  <root level="WARN" >
+    <appender-ref ref="STDOUT" />
+  </root>
+</configuration>

payment/src/main/scala/org/camunda/worker/akka/sample/payment/Main.scala

@@ -35,7 +35,7 @@ object Main extends App {
 
   // start polling
   val pollActor = system.actorOf(PollActor.props(hostAddress = host, maxTasks = 5, waitTime= 100, lockTime = 600))
-  pollActor ! Poll(topicName = "orderProcess:payment", worker, variableNames = List("orderId"))
+  pollActor ! Poll(topicName = "orderProcess:payment", worker, variableNames = List("order"))
 
   // waiting for end
   val input = readLine()

payment/src/main/scala/org/camunda/worker/akka/sample/payment/PaymentWorker.scala

@@ -8,17 +8,23 @@ import org.camunda.worker.akka.client.VariableValue
 import org.camunda.worker.akka.Worker
 import scala.concurrent.duration._
 import scala.util.Random
+import net.liftweb.json.JsonAST.JValue
+import net.liftweb.json._
+import net.liftweb.json.JsonDSL._
 
 /**
  * sample worker
  */
 class PaymentWorker(delay: Duration) extends Worker {
 
+  // default formats for json
+  implicit val formats = DefaultFormats
+  
   def work(task: LockedTask): Map[String, VariableValue] = {
 
-    val orderId = task.variables.get("orderId") match {
-      case Some(variableValue)  => variableValue.asValue[String]
-      case None                 => "" // throw IllegalArgumentException("no order id available")
+    val orderId: String = task.variable[JValue]("order") match {
+      case Some(json) => (json \ "orderId").extract[String]
+      case None       => "" // throw new IllegalArgumentException("order is not available")
     }
 
     val payment = calculatePayment(orderId)