diff --git a/dhp-common/src/main/java/eu/dnetlib/dhp/message/Message.java b/dhp-common/src/main/java/eu/dnetlib/dhp/message/Message.java
index 0cbb6c859..ecccf8a43 100644
--- a/dhp-common/src/main/java/eu/dnetlib/dhp/message/Message.java
+++ b/dhp-common/src/main/java/eu/dnetlib/dhp/message/Message.java
@@ -19,6 +19,8 @@ public class Message implements Serializable {
 
 	private Map<String, String> body;
 
+	public Message() {}
+
 	public Message(final MessageType messageType, final String workflowId) {
 		this(messageType, workflowId, new LinkedHashMap<>());
 	}
@@ -33,6 +35,10 @@ public class Message implements Serializable {
 		return messageType;
 	}
 
+	public void setMessageType(MessageType messageType) {
+		this.messageType = messageType;
+	}
+
 	public String getWorkflowId() {
 		return workflowId;
 	}
diff --git a/dhp-common/src/main/java/eu/dnetlib/dhp/message/MessageType.java b/dhp-common/src/main/java/eu/dnetlib/dhp/message/MessageType.java
index 30f152c96..75ffb8ef5 100644
--- a/dhp-common/src/main/java/eu/dnetlib/dhp/message/MessageType.java
+++ b/dhp-common/src/main/java/eu/dnetlib/dhp/message/MessageType.java
@@ -1,11 +1,12 @@
 
 package eu.dnetlib.dhp.message;
 
+import java.io.Serializable;
 import java.util.Optional;
 
 import org.apache.commons.lang3.StringUtils;
 
-public enum MessageType {
+public enum MessageType implements Serializable {
 
 	ONGOING, REPORT;