Skip to content

Commit

Permalink
Add lifecycle support for agents #84
Browse files Browse the repository at this point in the history
insert socket id to handshakedata.
  • Loading branch information
koo-taejin committed Jun 8, 2015
1 parent 3bf2a86 commit 381c49f
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down Expand Up @@ -186,7 +187,10 @@ public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) thr

registerPing();

Map<String, Object> handshakeData = this.pinpointSocketFactory.getProperties();
Map<String, Object> handshakeData = new HashMap<String, Object>();
handshakeData.putAll(pinpointSocketFactory.getProperties());
handshakeData.put("socketId", socketId);

handshaker.handshakeStart(channel, handshakeData);

connectFuture.setResult(Result.SUCCESS);
Expand Down

0 comments on commit 381c49f

Please # to comment.