public SyncClientSerializationStreamWriter(Serializer serializer, String moduleBaseURL, String serializationPolicyStrongName, SerializationPolicy serializationPolicy, RpcToken rpcToken) { this.serializer = serializer; this.moduleBaseURL = moduleBaseURL; this.serializationPolicyStrongName = serializationPolicyStrongName; this.serializationPolicy = serializationPolicy; this.rpcToken = rpcToken; if (rpcToken != null) { addFlags(FLAG_RPC_TOKEN_INCLUDED); } }
@Override public String getSerializationSignature(Class<?> clazz) { for (Serializer serializer : this.serializers) { String signature = serializer.getSerializationSignature(clazz); if (signature != null) { return signature; } } return null; }
@Override public Object instantiate(SerializationStreamReader stream, String typeSignature) throws SerializationException { for (Serializer serializer : this.serializers) { try { Object o = serializer.instantiate(stream, typeSignature); if (o != null) { return o; } } catch (SerializationException e) { continue; } } throw new SerializationException(typeSignature); }
@Override public void serialize(SerializationStreamWriter stream, Object instance, String typeSignature) throws SerializationException { for (Serializer serializer : this.serializers) { try { serializer.serialize(stream, instance, typeSignature); return; } catch (SerializationException e) { continue; } } throw new SerializationException(typeSignature); }
@Override public void deserialize(SerializationStreamReader stream, Object instance, String typeSignature) throws SerializationException { for (Serializer serializer : this.serializers) { try { serializer.deserialize(stream, instance, typeSignature); return; } catch (SerializationException e) { continue; } } throw new SerializationException(typeSignature); }
public CommandParam(boolean lazy, boolean quiet, Serializer serializer, List params, List callbacks) { super(); this.lazy = lazy; this.quiet = quiet; this.serializer = serializer; this.params = params; this.callbacks = callbacks; }
public GwtRpcProxy(String moduleBaseURL, String remoteServiceRelativePath, String serializationPolicyName, Serializer serializer) { super(moduleBaseURL, remoteServiceRelativePath, serializationPolicyName, serializer); }
public CommandServiceCompositeSerializer(Collection<Serializer> serializers) { this.serializers = serializers; }
public CommandSerializationStreamFactory(Serializer serializer, String moduleBaseURL) { super(); this.serializer = serializer; this.moduleBaseURL = moduleBaseURL; }
public Serializer getSerializer() { return this.serializer; }
public StorageSerializationStreamWriter(Serializer serializer) { this.serializer = serializer; }
protected abstract Serializer getSerializer();