diff --git a/src/main/java/org/asamk/signal/JsonEvtLoopReceiveMessageHandler.java b/src/main/java/org/asamk/signal/JsonEvtLoopReceiveMessageHandler.java
new file mode 100644
index 00000000..579d052f
--- /dev/null
+++ b/src/main/java/org/asamk/signal/JsonEvtLoopReceiveMessageHandler.java
@@ -0,0 +1,61 @@
+package org.asamk.signal;
+
+/*
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+*/
+
+//import org.asamk.signal.*;
+import org.asamk.signal.commands.*;
+import org.asamk.signal.manager.Manager;
+import org.whispersystems.signalservice.api.messages.SignalServiceContent;
+import org.whispersystems.signalservice.api.messages.SignalServiceEnvelope;
+
+//import java.io.IOException;
+
+public class JsonEvtLoopReceiveMessageHandler implements Manager.ReceiveMessageHandler {
+
+	public interface ResponseEmitter {
+		public void emit( JsonEvtLoopStatusReport resp);
+	}
+	
+    final Manager m;
+    ResponseEmitter responseEmitter;
+
+    public JsonEvtLoopReceiveMessageHandler(Manager m) {
+        this.m = m;
+    }
+    
+    public JsonEvtLoopReceiveMessageHandler( Manager m, ResponseEmitter responseEmitter) {
+    	this.m = m;
+    	this.responseEmitter = responseEmitter;
+    }
+
+    @Override
+    public void handleMessage(SignalServiceEnvelope envelope, SignalServiceContent content, Throwable exception) {
+        //ObjectNode result = jsonProcessor.createObjectNode();
+    	JsonEvtLoopStatusReport resp = null;
+        if (exception != null) {
+        	resp = new JsonEvtLoopStatusReport( "error", null, "error", "JsonEvtLoopReceiveMessageHandler::handleMessage: Exception: " + exception.toString());
+            //result.putPOJO("error", new JsonError(exception));
+        }
+        if (envelope != null) {
+            //result.putPOJO("envelope", new JsonMessageEnvelope(envelope, content));
+        	resp = new JsonEvtLoopStatusReport( new JsonMessageEnvelope(envelope, content));
+        }
+    	if(resp == null) {
+    		new JsonEvtLoopStatusReport( "error",  null, "JsonEvtLoopReceiveMessageHandler::handleMessage: both exceptino and envelope is null!").emit();
+    	} else {
+    		if( this.responseEmitter != null) {
+    			this.responseEmitter.emit( resp);
+    		} else {
+    			resp.emit();
+    		}
+    	}
+    }
+}