recieveTransaction.kt

@InitiatedBy(protocol = "utxo-transaction-transmission-protocol")
class ReceiveTransactionFlow: ResponderFlow {
    private val log = LoggerFactory.getLogger(ReceiveTransactionFlow::class.java)

    @CordaInject
    lateinit var utxoLedgerService: UtxoLedgerService
    @Suspendable
    override fun call(session: FlowSession) {
        val transaction = utxoLedgerService.receiveTransaction(session)
        log.info("Received transaction - ${transaction.id}")
    }
}