mirror of
https://github.com/corda/corda.git
synced 2025-04-07 19:34:41 +00:00
CORDA-781 code layout cleaned up
This commit is contained in:
parent
b0517954a0
commit
5354c777ce
@ -70,7 +70,8 @@ abstract class AbstractAMQPSerializationScheme : SerializationScheme {
|
||||
|
||||
protected abstract fun rpcClientSerializerFactory(context: SerializationContext): SerializerFactory
|
||||
protected abstract fun rpcServerSerializerFactory(context: SerializationContext): SerializerFactory
|
||||
open protected val publicKeySerializer: CustomSerializer.Implements<PublicKey> = net.corda.nodeapi.internal.serialization.amqp.custom.PublicKeySerializer
|
||||
open protected val publicKeySerializer: CustomSerializer.Implements<PublicKey>
|
||||
= net.corda.nodeapi.internal.serialization.amqp.custom.PublicKeySerializer
|
||||
|
||||
private fun getSerializerFactory(context: SerializationContext): SerializerFactory {
|
||||
return serializerFactoriesForContexts.computeIfAbsent(Pair(context.whitelist, context.deserializationClassLoader)) {
|
||||
|
@ -23,7 +23,6 @@ class OverridePKSerializerTest {
|
||||
|
||||
override val schemaForDocumentation: Schema
|
||||
get() = TODO("not implemented") //To change initializer of created properties use File | Settings | File Templates.
|
||||
|
||||
}
|
||||
|
||||
class AMQPTestSerializationScheme : AbstractAMQPSerializationScheme() {
|
||||
@ -38,7 +37,6 @@ class OverridePKSerializerTest {
|
||||
}
|
||||
|
||||
override val publicKeySerializer = TestPublicKeySerializer()
|
||||
|
||||
}
|
||||
|
||||
class TestPublicKey : PublicKey {
|
||||
@ -53,7 +51,6 @@ class OverridePKSerializerTest {
|
||||
override fun getFormat(): String {
|
||||
TODO("not implemented") //To change body of created functions use File | Settings | File Templates.
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
@ -64,8 +61,5 @@ class OverridePKSerializerTest {
|
||||
Assertions
|
||||
.assertThatThrownBy { scheme.serialize(key, AMQP_P2P_CONTEXT) }
|
||||
.hasMessageMatching("Custom write call")
|
||||
|
||||
|
||||
}
|
||||
|
||||
}
|
@ -562,7 +562,8 @@ class SerializationOutputTests {
|
||||
val state = TransactionState(FooState(), FOO_PROGRAM_ID, MEGA_CORP)
|
||||
|
||||
val scheme = AMQPServerSerializationScheme()
|
||||
val func = scheme::class.superclasses.single { it.simpleName == "AbstractAMQPSerializationScheme" }.java.getDeclaredMethod("registerCustomSerializers", SerializerFactory::class.java)
|
||||
val func = scheme::class.superclasses.single { it.simpleName == "AbstractAMQPSerializationScheme" }
|
||||
.java.getDeclaredMethod("registerCustomSerializers", SerializerFactory::class.java)
|
||||
func.isAccessible = true
|
||||
|
||||
val factory = SerializerFactory(AllWhitelist, ClassLoader.getSystemClassLoader())
|
||||
|
Loading…
x
Reference in New Issue
Block a user