diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/managment/QuerySyncTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/managment/QuerySyncTestCase.java
index 90c0699384..fd45ebd0b5 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/managment/QuerySyncTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/managment/QuerySyncTestCase.java
@@ -27,7 +27,7 @@
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
import org.wso2.siddhi.core.stream.output.StreamCallback;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/function/CastFunctionExecutorTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/function/CastFunctionExecutorTestCase.java
index 313da6a8aa..106cf958a4 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/function/CastFunctionExecutorTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/function/CastFunctionExecutorTestCase.java
@@ -27,7 +27,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/join/JoinTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/join/JoinTestCase.java
index 07ae3b0e66..f0215be26f 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/join/JoinTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/join/JoinTestCase.java
@@ -27,7 +27,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import org.wso2.siddhi.query.api.exception.ExecutionPlanValidationException;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/JoinPartitionTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/JoinPartitionTestCase.java
index a3a507c63c..4e8539c11d 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/JoinPartitionTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/JoinPartitionTestCase.java
@@ -26,7 +26,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.stream.input.InputHandler;
import org.wso2.siddhi.core.stream.output.StreamCallback;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/PartitionTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/PartitionTestCase.java
index c3de6b2323..b63fab76b5 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/PartitionTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/PartitionTestCase.java
@@ -26,7 +26,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.stream.input.InputHandler;
import org.wso2.siddhi.core.stream.output.StreamCallback;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import org.wso2.siddhi.query.api.ExecutionPlan;
import org.wso2.siddhi.query.api.annotation.Annotation;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/PatternPartitionTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/PatternPartitionTestCase.java
index 92640e1c6f..587df67674 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/PatternPartitionTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/PatternPartitionTestCase.java
@@ -26,7 +26,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.stream.input.InputHandler;
import org.wso2.siddhi.core.stream.output.StreamCallback;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/TablePartitionTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/TablePartitionTestCase.java
index 7b5e5effa8..76f4d2c4f0 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/TablePartitionTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/partition/TablePartitionTestCase.java
@@ -27,7 +27,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.stream.input.InputHandler;
import org.wso2.siddhi.core.stream.output.StreamCallback;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/pattern/ComplexPatternTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/pattern/ComplexPatternTestCase.java
index cc9f832557..3a5ac8aa82 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/pattern/ComplexPatternTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/pattern/ComplexPatternTestCase.java
@@ -27,8 +27,6 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
-import org.wso2.siddhi.core.stream.output.StreamCallback;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/ratelimit/SnapshotOutputRateLimitTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/ratelimit/SnapshotOutputRateLimitTestCase.java
index 8e6038f7fb..d81b21735e 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/ratelimit/SnapshotOutputRateLimitTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/ratelimit/SnapshotOutputRateLimitTestCase.java
@@ -28,7 +28,7 @@
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
import org.wso2.siddhi.core.stream.output.StreamCallback;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/IndexTableTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/IndexTableTestCase.java
index 785e0e5f4c..8b0523a598 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/IndexTableTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/IndexTableTestCase.java
@@ -27,7 +27,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.ArrayList;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/IndexedByTableTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/IndexedByTableTestCase.java
index 2a826fc27a..45284af66d 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/IndexedByTableTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/IndexedByTableTestCase.java
@@ -27,7 +27,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.ArrayList;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/LocgicalTableTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/LocgicalTableTestCase.java
index bce0b94489..b4d674611a 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/LocgicalTableTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/LocgicalTableTestCase.java
@@ -27,7 +27,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.ArrayList;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/PrimaryKeyTableTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/PrimaryKeyTableTestCase.java
index d0e12b01c1..0f3945f689 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/PrimaryKeyTableTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/query/table/PrimaryKeyTableTestCase.java
@@ -27,7 +27,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.query.output.callback.QueryCallback;
import org.wso2.siddhi.core.stream.input.InputHandler;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.ArrayList;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/stream/ExceptionHandlerTestCase.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/stream/ExceptionHandlerTestCase.java
index c29aa74f86..1202d33df1 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/stream/ExceptionHandlerTestCase.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/stream/ExceptionHandlerTestCase.java
@@ -44,7 +44,7 @@
import org.wso2.siddhi.core.event.Event;
import org.wso2.siddhi.core.stream.input.InputHandler;
import org.wso2.siddhi.core.stream.output.StreamCallback;
-import org.wso2.siddhi.core.test.util.SiddhiTestHelper;
+import org.wso2.siddhi.core.util.SiddhiTestHelper;
import org.wso2.siddhi.core.util.EventPrinter;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/test/util/SiddhiTestHelper.java b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/util/SiddhiTestHelper.java
similarity index 98%
rename from modules/siddhi-core/src/test/java/org/wso2/siddhi/core/test/util/SiddhiTestHelper.java
rename to modules/siddhi-core/src/test/java/org/wso2/siddhi/core/util/SiddhiTestHelper.java
index cdbbd07eda..69f655a656 100644
--- a/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/test/util/SiddhiTestHelper.java
+++ b/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/util/SiddhiTestHelper.java
@@ -16,7 +16,7 @@
* under the License.
*/
-package org.wso2.siddhi.core.test.util;
+package org.wso2.siddhi.core.util;
import java.util.Arrays;
import java.util.Collection;
diff --git a/modules/siddhi-extensions/transport/tcp-transport/pom.xml b/modules/siddhi-extensions/transport/tcp-transport/pom.xml
index efddc0a17b..ad39c70074 100644
--- a/modules/siddhi-extensions/transport/tcp-transport/pom.xml
+++ b/modules/siddhi-extensions/transport/tcp-transport/pom.xml
@@ -60,131 +60,35 @@
junit
junit
- 3.8.1
test
io.netty
netty-all
- 4.1.0.Final
org.apache.commons
commons-collections4
- 4.0
org.wso2.siddhi
siddhi-query-api
- ${siddhi.version}
org.wso2.siddhi
siddhi-query-compiler
- ${siddhi.version}
org.wso2.siddhi
siddhi-core
- ${siddhi.version}
com.google.code.gson
gson
- ${gson.version}
org.json.wso2
json
- ${orbit.version.json}
-
-
- UTF-8
-
- 2.5
- 2.0.0.wso2v1
-
-
-
-
- wso2-nexus
- WSO2 internal Repository
- http://maven.wso2.org/nexus/content/groups/wso2-public/
-
- true
- daily
- ignore
-
-
-
-
- wso2.releases
- WSO2 internal Repository
- http://maven.wso2.org/nexus/content/repositories/releases/
-
- true
- daily
- ignore
-
-
-
-
- wso2.snapshots
- Apache Snapshot Repository
- http://maven.wso2.org/nexus/content/repositories/snapshots/
-
- true
- daily
-
-
- false
-
-
-
-
-
- sonatype.releases
- https://oss.sonatype.org/content/repositories/releases/
-
-
-
-
-
-
- wso2.releases
- WSO2 internal Repository
- http://maven.wso2.org/nexus/content/repositories/releases/
-
- true
- daily
- ignore
-
-
-
-
- wso2.snapshots
- Apache Snapshot Repository
- http://maven.wso2.org/nexus/content/repositories/snapshots/
-
- true
- daily
-
-
- false
-
-
-
-
- wso2-nexus
- WSO2 internal Repository
- http://maven.wso2.org/nexus/content/groups/wso2-public/
-
- true
- daily
- ignore
-
-
-
diff --git a/pom.xml b/pom.xml
index 1ee0ecedf6..a49d47a279 100644
--- a/pom.xml
+++ b/pom.xml
@@ -315,7 +315,16 @@
jackson-datatype-joda
${jackson-datatype-joda-version}
-
+
+ io.netty
+ netty-all
+ ${netty-version}
+
+
+ org.apache.commons
+ commons-collections4
+ ${commons-collection-version}
+
@@ -521,6 +530,8 @@
2.4.1
2.5
2.4.1
+ 4.1.0.Final
+ 4.0