artin/OBP-API
1
0
Fork 0
mirror of https://github.com/OpenBankProject/OBP-API.git synced 2026-02-06 15:56:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Updated ObpJvmMappedConnector to reflect changes in OBP-JVM version 2016.11-RC6-SNAPSHOT

Browse Source
This commit is contained in:
Petar Bozin 2017-01-16 11:29:32 +01:00
parent b567ba724f
commit 6867165860
2 changed files with 12 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -15,7 +15,7 @@
<scala.compiler>2.11.8</scala.compiler>
<akka.version>2.4.10</akka.version>
<lift.version>2.6.3</lift.version>
<obp-ri.version>2016.11-RC5-SNAPSHOT</obp-ri.version>
<obp-ri.version>2016.11-RC6-SNAPSHOT</obp-ri.version>
<!-- Common plugin settings -->
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>${project.build.sourceEncoding}</project.reporting.outputEncoding>

25
src/main/scala/code/bankconnectors/ObpJvmMappedConnector.scala
View File

@ -25,7 +25,7 @@ import code.transactionrequests.MappedTransactionRequest
import code.transactionrequests.TransactionRequests._
import code.util.{Helper, TTLCache}
import code.views.Views
import com.tesobe.obp.kafka.SimpleNorth
import com.tesobe.obp.kafka.{Configuration, SimpleConfiguration, SimpleNorth}
import com.tesobe.obp.transport.{Pager, Transport}
import net.liftweb.common._
import net.liftweb.mapper._
@ -53,21 +53,18 @@ object ObpJvmMappedConnector extends Connector with Loggable {
var jvmNorth : JConnector = null
val producerProps : JHashMap = new JHashMap
val consumerProps : JHashMap = new JHashMap
val cfg: Configuration = new SimpleConfiguration(
this,
Props.get("kafka.host").openOr("localhost:9092"), // responseProps
Props.get("kafka.response_topic").openOr("Response"), // responseTopic
Props.get("kafka.host").openOr("localhost:9092"), // requestProps
Props.get("kafka.request_topic").openOr("Request") // requestTopic
)
consumerProps.put("bootstrap.servers",
Props.get("kafka.host").openOr("localhost:9092"))
producerProps.put("bootstrap.servers",
Props.get("kafka.host").openOr("localhost:9092"))
val factory = Transport.factory(Transport.Version.Nov2016, Transport.Encoding.json).get
val north = new SimpleNorth(
Props.get("kafka.response_topic").openOr("Response"),
Props.get("kafka.request_topic").openOr("Request"),
consumerProps, producerProps)
jvmNorth = factory.connector(north)
val north = new SimpleNorth( cfg )
jvmNorth = Transport.defaultFactory.connector(north)
north.receive() // start ObpJvm
logger.info(s"ObpJvmMappedConnector running")
// Local TTL Cache