package Ġnet . cord a . node api . internal . serialization . test utils Ċ Ċ import Ġnet . cord a . node api . internal . rpc . client . Rpc Client Observable De Serializer Ċ import Ġnet . cord a . core . context . Trace Ċ import Ġnet . cord a . core . serialization . Serialization Context Ċ import Ġnet . cord a . core . serialization . Serialization Custom Serializer Ċ import Ġnet . cord a . core . serialization . Serialization Whitelist Ċ import Ġnet . cord a . node api . internal . serialization . amqp . Rpc Server Observable Serializer Ċ import Ġnet . cord a . node api . RPC Api Ċ import Ġnet . cord a . serialization . internal . C ord a Serialization Magic Ċ import Ġnet . cord a . serialization . internal . All Whitelist Ċ import Ġnet . cord a . serialization . internal . amqp .* Ċ import Ġnet . cord a . node api . internal . rpc . client . Observable Context Ġas ĠClient Observable Context Ċ Ċ /** Ċ Ġ* ĠSpecial Ġserialization Ġcontext Ġfor Ġthe Ġround Ġtrip Ġtests Ġthat Ġallows Ġfor Ġboth Ġserver Ġand Ġclient ĠRPC Ċ Ġ* Ġoperations Ċ Ġ*/ ĊĊ Ċ class ĠAM Q PR ound Trip RPC Serialization Scheme ( ĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġserialization Context : ĠSerialization Context , ĊĠĠĠĠĠĠĠ Ġc ord app Custom Serial izers : ĠSet < Serialization Custom Serializer < *, Ġ* >>, ĊĠĠĠĠĠĠĠ Ġc ord app Serialization Wh itel ists : ĠSet < Serialization Whitelist >, ĊĠĠĠĠĠĠĠ Ġserializer Factories For Contexts : ĠMutable Map < Serialization Factory CacheKey , ĠSerializer Factory >) ĊĠĠĠ Ġ: ĠAbstract AM QP Serialization Scheme ( ĊĠĠĠĠĠĠĠ Ġc ord app Custom Serial izers , Ġc ord app Serialization Wh itel ists , Ġserializer Factories For Contexts Ċ ) Ġ{ ĊĠĠĠ Ġoverride Ġfun Ġrpc Client Serializer Factory ( context : ĠSerialization Context ): ĠSerializer Factory Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠSerializer Factory Builder . build ( All Whitelist , Ġjava Class . class Loader ). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġregister ( Rpc Client Observable De Serializer ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġrpc Server Serializer Factory ( context : ĠSerialization Context ): ĠSerializer Factory Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠSerializer Factory Builder . build ( All Whitelist , Ġjava Class . class Loader ). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġregister ( Rpc Server Observable Serializer ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġcan Deserialize Version ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmagic : ĠC ord a Serialization Magic , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtarget : ĠSerialization Context . UseCase ) Ġ= Ġtrue ĊĊĠĠĠ Ġfun Ġrpc Client Serializer Factory ( observable Context : ĠClient Observable Context , Ġid : ĠTrace . Invocation Id ) Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġrpc Client Serializer Factory ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠRpc Client Observable De Serializer . create Context ( serialization Context , Ġobservable Context ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. with Property ( RPC Api . Rpc Request Or Observable Id Key , Ġid )) ĊĊĠĠĠ Ġfun Ġrpc Server Serializer Factory ( observable Context : ĠTest Observable Context ) Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġrpc Server Serializer Factory ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠRpc Server Observable Serializer . create Context ( serialization Context , Ġobservable Context )) Ċ }