mirror of
https://github.com/corda/corda.git
synced 2025-06-22 17:09:00 +00:00
Move protocols into correct package
This commit is contained in:
@ -1,4 +1,4 @@
|
|||||||
package protocols
|
package com.r3corda.protocols
|
||||||
|
|
||||||
import co.paralleluniverse.fibers.Suspendable
|
import co.paralleluniverse.fibers.Suspendable
|
||||||
import com.r3corda.core.contracts.*
|
import com.r3corda.core.contracts.*
|
@ -1,4 +1,4 @@
|
|||||||
package protocols
|
package com.r3corda.protocols
|
||||||
|
|
||||||
import co.paralleluniverse.fibers.Suspendable
|
import co.paralleluniverse.fibers.Suspendable
|
||||||
import com.r3corda.core.contracts.*
|
import com.r3corda.core.contracts.*
|
||||||
@ -31,7 +31,7 @@ object NotaryChangeProtocol: AbstractStateReplacementProtocol<Party>() {
|
|||||||
override val topic: String get() = TOPIC
|
override val topic: String get() = TOPIC
|
||||||
|
|
||||||
override fun assembleProposal(stateRef: StateRef, modification: Party, stx: SignedTransaction): AbstractStateReplacementProtocol.Proposal<Party>
|
override fun assembleProposal(stateRef: StateRef, modification: Party, stx: SignedTransaction): AbstractStateReplacementProtocol.Proposal<Party>
|
||||||
= NotaryChangeProtocol.Proposal(stateRef, modification, stx)
|
= Proposal(stateRef, modification, stx)
|
||||||
|
|
||||||
override fun assembleTx(): Pair<SignedTransaction, List<PublicKey>> {
|
override fun assembleTx(): Pair<SignedTransaction, List<PublicKey>> {
|
||||||
val state = originalState.state
|
val state = originalState.state
|
@ -5,8 +5,8 @@ import com.r3corda.core.messaging.MessagingService
|
|||||||
import com.r3corda.core.node.services.NetworkMapCache
|
import com.r3corda.core.node.services.NetworkMapCache
|
||||||
import com.r3corda.node.services.api.AbstractNodeService
|
import com.r3corda.node.services.api.AbstractNodeService
|
||||||
import com.r3corda.node.services.statemachine.StateMachineManager
|
import com.r3corda.node.services.statemachine.StateMachineManager
|
||||||
import protocols.AbstractStateReplacementProtocol
|
import com.r3corda.protocols.AbstractStateReplacementProtocol
|
||||||
import protocols.NotaryChangeProtocol
|
import com.r3corda.protocols.NotaryChangeProtocol
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A service that monitors the network for requests for changing the notary of a state,
|
* A service that monitors the network for requests for changing the notary of a state,
|
||||||
|
@ -10,12 +10,12 @@ import com.r3corda.node.internal.AbstractNode
|
|||||||
import com.r3corda.node.internal.testing.MockNetwork
|
import com.r3corda.node.internal.testing.MockNetwork
|
||||||
import com.r3corda.node.services.network.NetworkMapService
|
import com.r3corda.node.services.network.NetworkMapService
|
||||||
import com.r3corda.node.services.transactions.SimpleNotaryService
|
import com.r3corda.node.services.transactions.SimpleNotaryService
|
||||||
|
import com.r3corda.protocols.NotaryChangeProtocol
|
||||||
|
import com.r3corda.protocols.NotaryChangeProtocol.Instigator
|
||||||
|
import com.r3corda.protocols.StateReplacementException
|
||||||
|
import com.r3corda.protocols.StateReplacementRefused
|
||||||
import org.junit.Before
|
import org.junit.Before
|
||||||
import org.junit.Test
|
import org.junit.Test
|
||||||
import protocols.NotaryChangeProtocol
|
|
||||||
import protocols.NotaryChangeProtocol.Instigator
|
|
||||||
import protocols.StateReplacementException
|
|
||||||
import protocols.StateReplacementRefused
|
|
||||||
import java.time.Instant
|
import java.time.Instant
|
||||||
import java.util.*
|
import java.util.*
|
||||||
import java.util.concurrent.ExecutionException
|
import java.util.concurrent.ExecutionException
|
||||||
|
Reference in New Issue
Block a user