Java 类com.esotericsoftware.kryo.util.MapReferenceResolver 实例源码

项目:vertexium    文件:KryoFactory.java   
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;
}
项目:subzero    文件:KryoStrategy.java   
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;
}
项目:apex-core    文件:DefaultStatefulStreamCodec.java   
@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();
}
项目:vis-editor    文件:KryoUtils.java   
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;
}
项目:spliceengine    文件:KryoPool.java   
@Override
public Kryo newInstance() {
    Kryo next = new Kryo(new DefaultClassResolver(),new MapReferenceResolver());
    if(kryoRegistry!=null)
        kryoRegistry.register(next);
    return next;
}
项目:hekate    文件:KryoCodec.java   
private Kryo statelessKryo() {
    return new Kryo(new DefaultClassResolver(), new MapReferenceResolver());
}
项目:hekate    文件:KryoCodec.java   
private Kryo statefulKryo() {
    return new Kryo(new NonResettableClassResolver(), new MapReferenceResolver());
}
项目:EsperDist    文件:Kryo.java   
/** Creates a new Kryo with a {@link DefaultClassResolver} and a {@link MapReferenceResolver}. */
public Kryo () {
    this(new DefaultClassResolver(), new MapReferenceResolver(), new DefaultStreamFactory());
}
项目:EsperDist    文件:Kryo.java   
/** Creates a new Kryo with a {@link DefaultClassResolver} and a {@link MapReferenceResolver}. */
public Kryo () {
    this(new DefaultClassResolver(), new MapReferenceResolver(), new DefaultStreamFactory());
}
项目:JourneyPlanner    文件:Kryo.java   
/** Creates a new Kryo with a {@link DefaultClassResolver} and a {@link MapReferenceResolver}. */
public Kryo () {
    this(new DefaultClassResolver(), new MapReferenceResolver(), new DefaultStreamFactory());
}
项目:kryo-mavenized    文件:Kryo.java   
/** Creates a new Kryo with a {@link DefaultClassResolver} and a {@link MapReferenceResolver}. */
public Kryo () {
    this(new DefaultClassResolver(), new MapReferenceResolver(), new DefaultStreamFactory());
}