From 381c49f61afd07a3469f4678e5c37690e93f55dd Mon Sep 17 00:00:00 2001 From: "koo.taejin" Date: Mon, 8 Jun 2015 11:55:16 +0900 Subject: [PATCH] Add lifecycle support for agents #84 insert socket id to handshakedata. --- .../pinpoint/rpc/client/PinpointSocketHandler.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/rpc/src/main/java/com/navercorp/pinpoint/rpc/client/PinpointSocketHandler.java b/rpc/src/main/java/com/navercorp/pinpoint/rpc/client/PinpointSocketHandler.java index dd769dbe3f48..06111f675e5f 100644 --- a/rpc/src/main/java/com/navercorp/pinpoint/rpc/client/PinpointSocketHandler.java +++ b/rpc/src/main/java/com/navercorp/pinpoint/rpc/client/PinpointSocketHandler.java @@ -17,6 +17,7 @@ package com.navercorp.pinpoint.rpc.client; import java.net.SocketAddress; +import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; @@ -186,7 +187,10 @@ public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) thr registerPing(); - Map handshakeData = this.pinpointSocketFactory.getProperties(); + Map handshakeData = new HashMap(); + handshakeData.putAll(pinpointSocketFactory.getProperties()); + handshakeData.put("socketId", socketId); + handshaker.handshakeStart(channel, handshakeData); connectFuture.setResult(Result.SUCCESS);