public Kryo createKryo() { Kryo kryo = new Kryo(new DefaultClassResolver(), new MapReferenceResolver() { @Override public boolean useReferences(Class type) { // avoid calling System.identityHashCode if (type == String.class || type == Date.class) { return false; } return super.useReferences(type); } }); registerClasses(kryo); kryo.setAutoReset(true); kryo.setInstantiatorStrategy(new Kryo.DefaultInstantiatorStrategy(new StdInstantiatorStrategy())); return kryo; }
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; }
@SuppressWarnings("OverridableMethodCallInConstructor") public DefaultStatefulStreamCodec() { super(new ClassResolver(), new MapReferenceResolver()); data = new Output(4096, Integer.MAX_VALUE); state = new Output(4096, Integer.MAX_VALUE); input = new Input(); register(Class.class); register(ClassIdPair.class); classResolver = (ClassResolver)getClassResolver(); this.pairs = classResolver.pairs; classResolver.init(); dataStatePair = new DataStatePair(); }
public static Kryo getCommonSettingsKryo () { Kryo kryo = new Kryo(new VisKryoClassResolver(), new MapReferenceResolver()); kryo.setInstantiatorStrategy(new DefaultInstantiatorStrategy(new StdInstantiatorStrategy())); kryo.setDefaultSerializer(new SettingsSerializerFactory()); kryo.register(Array.class, new ArraySerializer(), 10); kryo.register(UUID.class, new UUIDSerializer(), 12); kryo.register(Color.class, new ColorSerializer(), 11); kryo.register(Texture.TextureFilter.class, 13); return kryo; }
@Override public Kryo newInstance() { Kryo next = new Kryo(new DefaultClassResolver(),new MapReferenceResolver()); if(kryoRegistry!=null) kryoRegistry.register(next); return next; }
private Kryo statelessKryo() { return new Kryo(new DefaultClassResolver(), new MapReferenceResolver()); }
private Kryo statefulKryo() { return new Kryo(new NonResettableClassResolver(), new MapReferenceResolver()); }
/** Creates a new Kryo with a {@link DefaultClassResolver} and a {@link MapReferenceResolver}. */ public Kryo () { this(new DefaultClassResolver(), new MapReferenceResolver(), new DefaultStreamFactory()); }