1. remove data-carrier. 2.restore test case. 3. ready to suppor multi-constructor enhance.

skywalking-alarm/pom.xml

@@ -71,11 +71,6 @@
 			<artifactId>HikariCP</artifactId>
 			<version>2.4.3</version>
 		</dependency>
-		<dependency>
-			<groupId>com.a.eye</groupId>
-			<artifactId>data-carrier</artifactId>
-			<version>1.0</version>
-		</dependency>
 	</dependencies>
 	<build>
 		<plugins>

skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/plugin/interceptor/enhance/ClassEnhancePluginDefine.java

@@ -68,7 +68,9 @@ public abstract class ClassEnhancePluginDefine extends AbstractClassEnhancePlugi
             constructorInterceptor = "com.a.eye.skywalking.plugin.interceptor.assist.DefaultConstructorInterceptor";
         }
 
-        newClassBuilder = newClassBuilder.defineField(contextAttrName, EnhancedClassInstanceContext.class, ACC_PRIVATE).constructor(any()).intercept(SuperMethodCall.INSTANCE
+        newClassBuilder = newClassBuilder.defineField(contextAttrName, EnhancedClassInstanceContext.class, ACC_PRIVATE);
+
+        newClassBuilder = newClassBuilder.constructor(any()).intercept(SuperMethodCall.INSTANCE
                 .andThen(MethodDelegation.to(new ClassConstructorInterceptor(constructorInterceptor)).appendParameterBinder(FieldProxy.Binder.install(FieldGetter.class, FieldSetter.class))));
 
         if(existedMethodsInterceptPoints) {

skywalking-storage-center/skywalking-storage/src/test/java/StorageClient.java

@@ -2,8 +2,8 @@ import java.util.concurrent.CountDownLatch;
 
 public class StorageClient {
 
-    private static       int  THREAD_COUNT = 1;
-    private static final long COUNT        = 1;
+    private static       int  THREAD_COUNT = 4;
+    private static final long COUNT        = 1_000_000_000;
 
 
     public static void main(String[] args) throws InterruptedException {

skywalking-storage-center/skywalking-storage/src/test/java/StorageThread.java

@@ -23,7 +23,7 @@ public class StorageThread extends Thread {
 
     StorageThread(long count, CountDownLatch countDownLatch, int index) {
         listener = new MyStorageClientListener();
-        client = new Client("127.0.0.1", 23000).newSpanStorageClient(listener);
+        client = new Client("10.128.7.241", 34000).newSpanStorageClient(listener);
         this.count = count;
         this.countDownLatch = countDownLatch;
         this.index = index;
@@ -40,22 +40,25 @@ public class StorageThread extends Thread {
             RequestSpan requestSpan = RequestSpan.newBuilder().setSpanType(1).setAddress(NetUtils.getLocalAddress().toString()).setApplicationId("1").setCallType("1").setLevelId(0)
                     .setProcessNo(19287).setStartDate(System.currentTimeMillis())
                     .setTraceId(TraceId.newBuilder().addSegments(201611).addSegments(value).addSegments(8504828).addSegments(2277).addSegments(53).addSegments(3).build())
-                    .setUserId("1").setViewPointId("http://localhost:8080/wwww/test/helloWorld").build();
+                    .setUserId("1").setViewPointId("http://localhost:8080/wwww/test/helloWorld").setRouteKey(i).build();
 
             AckSpan ackSpan = AckSpan.newBuilder().setLevelId(0).setCost(10).setTraceId(
                     TraceId.newBuilder().addSegments(201611).addSegments(value).addSegments(8504828).addSegments(2277).addSegments(53).addSegments(3)
-                            .build()).setStatusCode(0).setViewpointId("http://localhost:8080/wwww/test/helloWorld").build();
+                            .build()).setStatusCode(0).setViewpointId("http://localhost:8080/wwww/test/helloWorld").setRouteKey(i).build();
             requestSpanList.add(requestSpan);
             ackSpanList.add(ackSpan);
             cycle++;
 
-            if (cycle == 1) {
+            if (cycle == 10) {
                 client.sendACKSpan(ackSpanList);
                 client.sendRequestSpan(requestSpanList);
                 cycle = 0;
 
                 while (!listener.isCompleted) {
-                    LockSupport.parkNanos(1);
+                    try {
+                        Thread.sleep(1L);
+                    } catch (InterruptedException e) {
+                    }
                 }
                 listener.begin();
                 ackSpanList.clear();