socket manager minor fix

DataINCITE · Mar 21, 2023 · 61f6b2e · 61f6b2e
1 parent 9095e63
commit 61f6b2e
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
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
@@ -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
@@ -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");