Commanq queue: a command and its companion specification class

PushTransactionForInvoice.kt

@Component
class PushTransactionForInvoice(
        private val transactionPushService: TransactionPushService
) : Command(PushTransactionForInvoiceSpec::class) {

    override fun execute(arguments: Map<String, Any?>): CommandExecutionResult {
        val invoiceId = InvoiceId(arguments["invoiceId"] as String)
        val transactionId = TransactionId(arguments["transactionId"] as String)

        transactionPushService.pushTransactionForInvoice(transactionId, invoiceId)

        // May return FailureOnOurSide or FailureOnProviderSide as well.
        // Any exception will be caught and considered a FailureOnOurSide, unless
        // CircuitBreaking.considerExceptionAsFailureIf tells it's a FailureOnProviderSide
        return Success
    }
}

class PushTransactionForInvoiceSpec(
        transactionId: TransactionId,
        invoiceId: InvoiceId
) : CommandSpecification(mapOf(
        "invoiceId" to invoiceId.get(),
        "transactionId" to transactionId.get()
)) {
    companion object {
        val COMMAND_NAME = "pushTransactionForInvoice"
    }
}