diff --git a/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/socket/SocketManager.java b/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/socket/SocketManager.java
index 2444deab..ff5f48f6 100644
--- a/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/socket/SocketManager.java	
+++ b/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/socket/SocketManager.java	
@@ -84,13 +84,13 @@ public void run() {
 					
 					// execute valid response to engine
 					Response response = producer.send(tag, sub_tag, data);
-//					out.writeUTF(new JSONObject()
-//							.put("response", "200")
-//							.put("code", response.code())
-//							.put("message", response.message())
-//							.put("data", response.data())
-//							.toString());
-//					out.flush();
+					out.writeUTF(new JSONObject()
+							.put("response", "200")
+							.put("code", response.code())
+							.put("message", response.message())
+							.put("data", response.data())
+							.toString());
+					out.flush();
 					
 				} catch(Exception e) {
 					break;
@@ -204,9 +204,9 @@ private static boolean synced(String key) {
 	private static final String readLine(DataInputStream in) throws IOException {
 		StringBuilder out = new StringBuilder();
 		char c = 0;
-		while((c = (char)in.read()) != 10)
+		while((c = (char)in.read()) != 10) {
 			out.append(c);
-		
+		}
 		return out.toString();
 	}
 }
diff --git a/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/properties/Config.java b/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/properties/Config.java
index fede1005..b64cd4a8 100644
--- a/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/properties/Config.java	
+++ b/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/properties/Config.java	
@@ -21,7 +21,7 @@ public class Config {
 	properties.put("app", app_properties);
 	
 	Properties stream_properties = new Properties();
-	stream_properties.put("general.consumer.types", "socket_consumer");
+	stream_properties.put("general.consumer.types", "null");
 	stream_properties.put("general.producer.types", "socket_producer");
 	stream_properties.put("rest.socket.address", "DataEngine");
 	//stream_properties.put("rest.socket.address", "localhost");