Tolerate duplicates to prevent a PK violation. (#2460)

This commit is contained in:
josecoll 2018-02-08 11:17:57 +00:00 committed by Katelyn Baker
parent 9b8fe3a1d4
commit 9c2b5f4ced

View File

@ -55,7 +55,7 @@ class DBTransactionMappingStorage : StateMachineRecordedTransactionMappingStorag
val updates: PublishSubject<StateMachineTransactionMapping> = PublishSubject.create()
override fun addMapping(stateMachineRunId: StateMachineRunId, transactionId: SecureHash) {
stateMachineTransactionMap[transactionId] = stateMachineRunId
stateMachineTransactionMap.addWithDuplicatesAllowed(transactionId, stateMachineRunId)
updates.bufferUntilDatabaseCommit().onNext(StateMachineTransactionMapping(stateMachineRunId, transactionId))
}