wip(worker): add payment service

Author: saig0

payment/README.md

@@ -0,0 +1,21 @@
+# Payment
+
+Payment microservice based on [Camunda-Worker-Akka](https://github.com/saig0/camunda-worker-akka).
+
+## Getting started
+
+> Requirements
+* [SBT](http://www.scala-sbt.org) to run and build the application 
+* Deployed version of Camunda-Worker-Akka
+
+Run application with
+```
+sbt run
+```
+
+Build application with
+```
+sbt assemply
+```
+
+The running application can shut down by press ENTER.

payment/build.sbt

@@ -0,0 +1,24 @@
+organization := "org.camunda"
+
+name := "Camunda-Akka-Worker-payment"
+
+version := "1.0.0-SNAPSHOT"
+
+scalaVersion := "2.11.7"
+
+resolvers += "Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/"
+
+libraryDependencies ++= Seq(
+  "org.camunda" %% "camunda-worker-akka" % "1.0.0-SNAPSHOT"
+ )
+
+assemblyMergeStrategy  in assembly := {
+  case x if x.startsWith("META-INF") => MergeStrategy.discard // Bumf
+  case x if x.endsWith(".html") => MergeStrategy.discard // More bumf
+  case x if x.contains("slf4j-api") => MergeStrategy.last
+  case x if x.contains("org/cyberneko/html") => MergeStrategy.first
+  case PathList("com", "esotericsoftware", xs@_ *) => MergeStrategy.last // For Log$Logger.class
+  case x =>
+     val oldStrategy = (mergeStrategy in assembly).value
+     oldStrategy(x)
+}

payment/project/assembly.sbt

@@ -0,0 +1 @@
+addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.13.0")

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

@@ -0,0 +1,43 @@
+
+
+package org.camunda.worker.akka/**
+ * @author Philipp Ossler
+ */
+
+import scala.collection.JavaConversions._
+import org.camunda.worker.akka.PollActor.Poll
+import org.camunda.worker.dto.LockedTaskDto
+import akka.actor._
+import org.camunda.worker.akka.worker._
+import scala.io.StdIn._
+
+/**
+ * @author Philipp Ossler
+ */
+object Main extends App {
+ 
+  println("")
+  println("starting...........")
+  println("press ENTER to exit")
+  println("===================")
+  println("")
+  
+  // create actor system
+  val system = ActorSystem("MyActorSystem")
+  
+  // create worker
+  val worker = system.actorOf(UnreliableWorker.props(delay = 200, reliability = 0.75), name = "worker-1")
+  
+  // start polling
+  val pollActor = system.actorOf(PollActor.props(hostAddress = "http://localhost:8080/engine-rest", maxTasks = 5, waitTime= 100, lockTime = 600), name = "poller")
+  pollActor ! Poll(topicName = "payment", worker)
+  
+  // waiting for end
+  val input = readLine()
+  println("")
+  println("===================")
+  println("shutting down......")
+  println("")
+  
+  system.shutdown
+}