tcp server updated
@@ -23,7 +23,6 @@ import org.wso2.siddhi.core.SiddhiAppRuntime;
import org.wso2.siddhi.core.SiddhiManager;
-
/**
* Test Server for TCP source.
*/
@@ -40,10 +39,6 @@ public class TCPServer {
SiddhiManager siddhiManager = new SiddhiManager();
String url = args[0];
String type = args[1];
-
- //This is for binary mapping
- if (args[1].equals("binary"))
- {
SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(
"@App:name('TestExecutionPlan') " +
"@source(type ='tcp',url = '" + url + "', context='LowProducitonAlertStream'," +
@@ -57,24 +52,5 @@ public class TCPServer {
siddhiAppRuntime.start();
while (true) {
}
- //This is for other mappings
- }
- else
- {
- SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(
- "@App:name('TestExecutionPlan') " +
- "@source(type ='tcp',url = '" + url + "', context='LowProducitonAlertStream'," +
- "@map(type='" + type + "',@payload(\"{{message}}\")))" +
- "define stream LowProducitonAlertStream (message string);\n" +
- "@sink(type='log')\n" +
- "define stream logStream(message string);\n" +
- "from LowProducitonAlertStream\n" +
- "select * \n" +
- "insert into logStream;");
- siddhiAppRuntime.start();
- while (true) {
- }
- }
-
}
}
