private Kryo newKryoInstance() { Kryo kryo; if (IGNORE_HAZELCAST_CLASSLOADER) { kryo = new Kryo(); } else { ClassLoader classLoader = ClassLoaderUtils.getConfiguredClassLoader(hazelcastInstance); DelegatingClassResolver classResolver = new DelegatingClassResolver(classLoader); MapReferenceResolver mapReferenceResolver = new MapReferenceResolver(); DefaultStreamFactory defaultStreamFactory = new DefaultStreamFactory(); kryo = new Kryo(classResolver, mapReferenceResolver, defaultStreamFactory); } registerCustomSerializers(kryo); kryo.setInstantiatorStrategy(new Kryo.DefaultInstantiatorStrategy(new StdInstantiatorStrategy())); return kryo; }
/** Creates a new Kryo with a {@link DefaultClassResolver} and a {@link MapReferenceResolver}. */ public Kryo () { this(new DefaultClassResolver(), new MapReferenceResolver(), new DefaultStreamFactory()); }
/** Creates a new Kryo with a {@link DefaultClassResolver}. * @param referenceResolver May be null to disable references. */ public Kryo (ReferenceResolver referenceResolver) { this(new DefaultClassResolver(), referenceResolver, new DefaultStreamFactory()); }
/** @param referenceResolver May be null to disable references. */ public Kryo (ClassResolver classResolver, ReferenceResolver referenceResolver) { this(classResolver, referenceResolver, new DefaultStreamFactory()); }