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

Closes #120 - Create KafkaOutBoundTransaciton case class instead of Map

Browse Source
This commit is contained in:
Marko Milic 2016-08-05 13:53:32 +02:00
parent 063f0f0ead
commit 7a1d095bd2
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/main/scala/code/bankconnectors/KafkaMappedConnector.scala
View File

@ -445,13 +445,13 @@ object KafkaMappedConnector extends Connector with CreateViewImpls with Loggable
val reqId: String = UUID.randomUUID().toString
// Create argument list with reqId
// in order to fetch corresponding response
val argObj = KafkaOutboundSaveTransaction(username = OBPUser.getCurrentUserUsername,
accountId = account.accountId.value,
currency = currency,
amount = amt.toString,
otherAccountId = counterparty.accountId.value,
otherAccountCurrency = counterparty.currency,
transactionType = "AC")
val argObj = KafkaOutboundTransaction(username = OBPUser.getCurrentUserUsername,
accountId = account.accountId.value,
currency = currency,
amount = amt.toString,
otherAccountId = counterparty.accountId.value,
otherAccountCurrency = counterparty.currency,
transactionType = "AC")
// Since result is single account, we need only first list entry
implicit val formats = net.liftweb.json.DefaultFormats
@ -1100,12 +1100,12 @@ object KafkaMappedConnector extends Connector with CreateViewImpls with Loggable
case class KafkaInboundTransactionId(
transactionId : String
)
case class KafkaOutboundSaveTransaction(username: String,
accountId: String,
currency: String,
amount: String,
otherAccountId: String,
otherAccountCurrency: String,
transactionType: String)
case class KafkaOutboundTransaction(username: String,
accountId: String,
currency: String,
amount: String,
otherAccountId: String,
otherAccountCurrency: String,
transactionType: String)
}