Merge pull request #142 from OpenBankProject/issue139

issue #139 - new KafkaLibMapeedConnector

pom.xml

@@ -209,6 +209,11 @@
       <artifactId>signpost-commonshttp4</artifactId>
       <version>1.2.1.2</version>
     </dependency>
+    <dependency>
+      <groupId>com.tesobe.obp</groupId>
+      <artifactId>obp-ri-kafka</artifactId>
+      <version>2016.0-SNAPSHOT</version>
+    </dependency>
   </dependencies>
 
   <build>

src/main/resources/props/sample.props.template

@@ -10,6 +10,7 @@
 connector=mapped
 #connector=mongodb
 #connector=kafka
+#connector=kafka_lib_v0
 #connector=...
 
 #if using kafka connector, set zookeeper host

src/main/scala/code/bankconnectors/Connector.scala

@@ -37,12 +37,19 @@ object Connector  extends SimpleInjector {
 
   val connector = new Inject(buildOne _) {}
 
-  def buildOne: Connector =
-    Props.get("connector").openOrThrowException("no connector set") match {
-      case "mapped" => LocalMappedConnector
-      case "mongodb" => LocalConnector
-      case "kafka" => KafkaMappedConnector
+  def buildOne: Connector = {
+    val connectorProps = Props.get("connector").openOrThrowException("no connector set")
+
+    if (connectorProps.startsWith("kafka_lib")) {
+      KafkaLibMappedConnector
+    } else {
+      connectorProps match {
+        case "mapped" => LocalMappedConnector
+        case "mongodb" => LocalConnector
+        case "kafka" => KafkaMappedConnector
+      }
     }
+  }
 
 }