dhp-schemas/src/main/java/eu/dnetlib/dhp/schema/action/AtomicAction.java

@@ -1,38 +0,0 @@
-package eu.dnetlib.dhp.schema.action;
-
-import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
-import eu.dnetlib.dhp.schema.oaf.Oaf;
-
-import java.io.Serializable;
-
-@JsonDeserialize(using = AtomicActionDeserializer.class)
-public class AtomicAction<T extends Oaf> implements Serializable {
-
-    private Class<T> clazz;
-
-    private T payload;
-
-    public AtomicAction() {
-    }
-
-    public AtomicAction(Class<T> clazz, T payload) {
-        this.clazz = clazz;
-        this.payload = payload;
-    }
-
-    public Class<T> getClazz() {
-        return clazz;
-    }
-
-    public void setClazz(Class<T> clazz) {
-        this.clazz = clazz;
-    }
-
-    public T getPayload() {
-        return payload;
-    }
-
-    public void setPayload(T payload) {
-        this.payload = payload;
-    }
-}

dhp-schemas/src/main/java/eu/dnetlib/dhp/schema/action/AtomicActionDeserializer.java

@@ -1,29 +0,0 @@
-package eu.dnetlib.dhp.schema.action;
-
-import com.fasterxml.jackson.core.JsonParser;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.DeserializationContext;
-import com.fasterxml.jackson.databind.JsonDeserializer;
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import eu.dnetlib.dhp.schema.oaf.Oaf;
-
-import java.io.IOException;
-
-public class AtomicActionDeserializer extends JsonDeserializer {
-
-    @Override
-    public Object deserialize(JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException {
-        JsonNode node = jp.getCodec().readTree(jp);
-        String classTag = node.get("clazz").asText();
-        JsonNode payload = node.get("payload");
-        ObjectMapper mapper = new ObjectMapper();
-
-        try {
-            final Class<?> clazz = Class.forName(classTag);
-            return new AtomicAction(clazz, (Oaf) mapper.readValue(payload.toString(), clazz));
-        } catch (ClassNotFoundException e) {
-            throw new IOException(e);
-        }
-    }
-}