Complex self defined Object serialize support. about hprose-java HOT 7 CLOSED

    void setIdentifier(String value);
    void setMetaData(MetaData value);
    void setPayload(T value);

public interface ITransferMsg<T> extends java.io.Serializable {
    String getIdentifier();

    MetaData getMetaData();

    T getPayload();

    Class<?> getPayloadType();

    void setIdentifier(String value);

    void setMetaData(MetaData value);

    void setPayload(T value);

    ITransferMsg<T> withMetaData(Map<String, Object> metaData);

    ITransferMsg<T> andMetaData(Map<String, Object> metaData);

    Map<String,Object> getMetaValue();
}

public class GenericTransferMsg<T> implements ITransferMsg<T> {
    private static final long serialVersionUID = -2860606356253432506L;
    private String identifier;
    private MetaData metaData;
    private Class<?> payloadType;
    private T payload;

    // for kryo default constructor is needed
    public GenericTransferMsg() {
        identifier = null;
        metaData = MetaData.emptyInstance();
        payload = null;
        payloadType = Void.TYPE;
    }

    /**
     * Constructs a Message for the given 
     * <code>payload</code> using empty metadata.
     * 
     * @param payload The payload for the message
     */
    public GenericTransferMsg(T payload) {
        this(payload, MetaData.emptyValues());
    }

    /**
     * Constructs a Message for the given 
     * <code>payload</code> and <code>meta data</code>.
     * 
     * @param payload The payload for the message
     * @param metaData The meta data for the message
     */
    public GenericTransferMsg(T payload, Map<String, Object> metaData) {
        this(UUIDHelper.random().toString(), payload, metaData);
    }

    /**
     * @param payload
     * @param metData
     */
    public GenericTransferMsg(T payload, MetaData metData) {
        this(UUIDHelper.random().toString(), payload, metData);
    }

    /**
     * Constructor to reconstruct a Message using existing data.
     * 
     * @param identifier The identifier of the Message
     * @param payload The payload of the message
     * @param metaData The meta data of the message
     */
    public GenericTransferMsg(String identifier, T payload, Map<String, Object> metaData) {
        this(identifier, payload, MetaData.from(metaData));
    }

    /**
     * Constructor to reconstruct a Message using existing data.
     * 
     * @param identifier The identifier of the Message
     * @param payload The payload of the message
     * @param metaData The meta data of the message
     */
    public GenericTransferMsg(String identifier, T payload, MetaData metaData) {
        this.identifier = identifier;
        this.metaData = metaData;
        this.payload = payload;
        this.payloadType = payload.getClass();
    }

    protected GenericTransferMsg(GenericTransferMsg<T> original, Map<String, Object> metaData) {
        this(original, MetaData.from(metaData));
    }

    protected GenericTransferMsg(GenericTransferMsg<T> original, MetaData metaData) {
        this.identifier = original.getIdentifier();
        this.payload = original.getPayload();
        this.payloadType = payload.getClass();
        this.metaData = metaData;
    }

    @Override
    public String getIdentifier() {
        return identifier;
    }

    @Override
    public MetaData getMetaData() {
        return metaData;
    }

    @Override
    public T getPayload() {
        return payload;
    }

    @Override
    public Class<?> getPayloadType() {
        return payloadType;
    }

    @Override
    public void setIdentifier(String value) {
        identifier = value;
    }

    @Override
    public void setMetaData(MetaData value) {
        metaData = value;
    }

    @Override
    public void setPayload(T value) {
        payload = value;
        payloadType = payload.getClass();
    }

    @Override
    public GenericTransferMsg<T> withMetaData(Map<String, Object> newMetaData) {
        return this.metaData.getValues().equals(newMetaData) ? this : new GenericTransferMsg<T>(this, newMetaData);
    }

    @Override
    public GenericTransferMsg<T> andMetaData(Map<String, Object> additionalMetaData) {
        return additionalMetaData.isEmpty() ? this : new GenericTransferMsg<T>(this, this.metaData.mergedWith(additionalMetaData));
    }

    @Override
    public Map<String, Object> getMetaValue() {
        return this.metaData.getValues();
    }


}

    void setIdentifier(String value);
    void setMetaData(MetaData value);
    void setPayload(T value);

public class GenericTransferMsg<T> implements ITransferMsg<T> {
    private static final long serialVersionUID = -2860606356253432506L;
    private final String identifier;
    private final MetaData metaData;
    private final transient Class<?> payloadType;
    private final T payload;
...
}

public interface MyRemoteCall {

    boolean transfer(ITransferMsg transferMsg);
}

HproseClient client = HproseClient.create(uri, HproseMode.FieldMode);
MyRemoteCall rc = client.useService(MyRemoteCall.class);
...