Java . lang . illegalargumentexception:无法在Corda中接收基元类型[int]

Question

我试图使用recveAll（）函数在PartyA（发起方）中接收有效负载。但是遇到了以下错误：

java.lang.IllegalArgumentException：执行流时无法接收基元类型[int]。

启动流程：

@InitiatingFlow
@StartableByRPC
class sendAllMapReceiveAll_IntExampleFlow(private val itemToBeSent : String,private val item2 : Int) : FlowLogic<String>(){
    @Suspendable
    override fun call():String {
        val counterParty1 = serviceHub.identityService.partiesFromName("PartyB",false).single()
        val counterParty2 = serviceHub.identityService.partiesFromName("PartyC",false).single()
        val counterPartySession1 = initiateFlow(counterParty1)
        val counterPartySession2 = initiateFlow(counterParty2)
        val sessionPayloadMap = mapOf(Pair(counterPartySession1,itemToBeSent), Pair(counterPartySession2,item2))
        sendAllMap(sessionPayloadMap)

        val receivedBack=receiveAll(Int::class.java, listOf(counterPartySession1,counterPartySession2)).map { it.unwrap { it } }

        return receivedBack.toString()
    }
}

响应程序流：

@InitiatedBy(sendAllMapReceiveAll_AnyExampleFlow::class)
class SendAllMapReceiveAllAnyResponder(private val counterSession : FlowSession): FlowLogic<Unit>(){
    @Suspendable
    override fun call(){
        val payloadItem  = counterSession.receive<Any>().unwrap { it }
        println("PayLoad Received at Responder = "+ payloadItem)
        counterSession.send(12346)
    }
}

后来为了解决这个错误。我发现这个链接很有帮助。通过在receiveAll()中将Int改为Integer，解决了这个问题。但是int在单接收函数中工作，如下所示:

val payloadItem  = counterSession.receive<Int>().unwrap { it }

1. 为什么primitive int在receiveAll（）中不工作，但同时在单个receive（session）中工作
2. kotlin中的其他基元类型在receiveAll（）中的行为也类似吗

编辑：再添加一个例子，给我同样的错误来解决答案中的混淆。

val receivedBack2 =receiveAllMap(mapOf(Pair(counterPartySession1,String::class.java),
                Pair(counterPartySession2,Int::class.java))).map { it.value.unwrap { it } }

Answer 1

我认为您提供的代码片段不准确。
错误消息清楚地提到您尝试接收原始int（小写i）；而在您的代码中，您编写了类Int（大写I）。

我认为最初你的代码中有int，你得到了那个错误，然后在发布问题时把它改成了Int。

send（）、receive（）、sendAndReceive（）仅适用于类（请参阅此处的文档）；因此它将与Int或Integer一起使用；它不能与int一起使用。