Skip to content

Commit 26ba104

Browse files
committed
fix for mismatch values of eventStats
1 parent 5e03fd1 commit 26ba104

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed

newrelic-security-agent/src/main/java/com/newrelic/agent/security/instrumentator/dispatcher/DispatcherPool.java

+1
Original file line numberDiff line numberDiff line change
@@ -239,6 +239,7 @@ public void dispatchExitEvent(ExitEventBean exitEventBean) {
239239
securityMetaData.addCustomAttribute(NR_APM_TRACE_ID, traceMetadata.getTraceId());
240240
securityMetaData.addCustomAttribute(NR_APM_SPAN_ID, traceMetadata.getSpanId());
241241
this.executor.submit(new Dispatcher(exitEventBean));
242+
AgentInfo.getInstance().getJaHealthCheck().getEventStats().getDispatcher().incrementSubmitted();
242243
AgentInfo.getInstance().getJaHealthCheck().getEventStats().getExitEvents().incrementSubmitted();
243244
}
244245

newrelic-security-agent/src/main/java/com/newrelic/agent/security/intcodeagent/websocket/EventSendPool.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ private EventSendPool() {
4646
protected void afterExecute(Runnable r, Throwable t) {
4747
try {
4848
if (r instanceof CustomFutureTask<?> && ((CustomFutureTask<?>) r).getTask() instanceof EventSender) {
49-
EventSender task = (EventSender) ((CustomFutureTask<?>) r).get();
49+
EventSender task = (EventSender) ((CustomFutureTask<?>) r).getTask();
5050
if(task.getEvent() instanceof JavaAgentEventBean){
5151
if (t != null) {
5252
AgentInfo.getInstance().getJaHealthCheck().getEventStats().getEventSender().incrementError();

newrelic-security-agent/src/main/java/com/newrelic/agent/security/intcodeagent/websocket/WSClient.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -262,7 +262,7 @@ private static void cleanIASTState() {
262262
public void onMessage(String message) {
263263
// Receive communication from IC side.
264264
try {
265-
AgentInfo.getInstance().getJaHealthCheck().getWebSocketConnectionStats().incrementMessagesSent();
265+
AgentInfo.getInstance().getJaHealthCheck().getWebSocketConnectionStats().incrementMessagesReceived();
266266
if (logger.isLogLevelEnabled(LogLevel.FINEST)) {
267267
logger.log(LogLevel.FINEST, String.format(INCOMING_CONTROL_COMMAND_S, message),
268268
this.getClass().getName());

0 commit comments

Comments
 (0)