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

Merge branch 'optionalMessageQueueUsage' into develop

Browse Source
This commit is contained in:
Ayoub BENALI 2014-02-21 13:52:28 +01:00
commit 86b01d8b1a
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/scala/bootstrap/liftweb/Boot.scala
View File

@ -230,6 +230,8 @@ class Boot extends Loggable{
// Make a transaction span the whole HTTP request
S.addAround(DB.buildLoanWrapper)
BankAccountCreationListener.startListen
val useMessageQueue = Props.getBool("messageQueue.createBankAccounts", false)
if(useMessageQueue)
BankAccountCreationListener.startListen
}
}

7
src/main/scala/code/model/dataAccess/Connectors.scala
View File

@ -40,13 +40,13 @@ import code.model.dataAccess.OBPEnvelope.OBPQueryParam
import net.liftweb.mapper.{By,SelectableField, ByList}
import net.liftweb.mongodb.MongoDB
import com.mongodb.BasicDBList
import java.util.ArrayList
import org.bson.types.ObjectId
import net.liftweb.db.DB
import net.liftweb.mongodb.JsonObject
import com.mongodb.QueryBuilder
import scala.concurrent.ops.spawn
import com.tesobe.model.UpdateBankAccount
import net.liftweb.util.Props
object LocalStorage extends MongoDBLocalStorage
@ -98,9 +98,12 @@ class MongoDBLocalStorage extends LocalStorage {
* It will be used each time we fetch transactions from the DB. But the test
* is performed in a different thread.
*/
private def updateAccountTransactions(bank: HostedBank, account: Account): Unit = {
spawn{
if( now after time(account.lastUpdate.get.getTime + hours(1)) ) {
val useMessageQueue = Props.getBool("messageQueue.updateBankAccountsTransaction", false)
val outDatedTransactions = now after time(account.lastUpdate.get.getTime + hours(1))
if(outDatedTransactions && useMessageQueue) {
UpdatesRequestSender.sendMsg(UpdateBankAccount(account.number.get, bank.national_identifier.get))
}
}