1 |
|
2 |
|
3 |
|
4 |
|
5 | var agentConfReader = require("./agent-setting");
|
6 | var util = require("./util");
|
7 |
|
8 | function AutoSensorMessageHandler(clientSocket) {
|
9 | this.clientSocket = clientSocket;
|
10 | this.handleMessages();
|
11 | }
|
12 |
|
13 | AutoSensorMessageHandler.prototype.handleMessages = function()
|
14 | {
|
15 | try {
|
16 | var clientSocket = this.clientSocket;
|
17 |
|
18 | var autoSensorMessage = "auto_sensor_thread_hotspot_data_req:appName=" + agentConfReader.getInstance() + ";appID="
|
19 | + agentConfReader.appID + ";ndAppServerID=" + agentConfReader.serverID + ";ndAppServerHost=" + agentConfReader.getServerName() + ";tierName=" + agentConfReader.getTierName()
|
20 | + ";tierID=" + agentConfReader.tierID + ";NDCollectorIP=" + agentConfReader.ndcHost + ";NDCollectorPort="
|
21 | + agentConfReader.ndcPort + ";testIdx=" + agentConfReader.currentTestRun + "\n";
|
22 |
|
23 | util.logger.info(agentConfReader.currentTestRun + " | " + autoSensorMessage);
|
24 |
|
25 | if (agentConfReader.isTestRunning) {
|
26 | try {
|
27 | clientSocket.write(autoSensorMessage);
|
28 | } catch (e) {
|
29 | util.logger.warn(agentConfReader.currentTestRun + " | " + e);
|
30 | }
|
31 | }
|
32 | }catch(e){util.logger.warn(agentConfReader.currentTestRun+" | "+e);}
|
33 | };
|
34 |
|
35 |
|
36 | module.exports = AutoSensorMessageHandler; |
\ | No newline at end of file |