@@ -2223,10 +2223,18 @@ public void onMessage(UUID nodeId, Object msg) {
22232223 try {
22242224 boolean processed = true ;
22252225
2226- if (msg instanceof GridQueryNextPageRequest )
2226+ boolean tracebleMsg = false ;
2227+
2228+ if (msg instanceof GridQueryNextPageRequest ) {
22272229 mapQueryExecutor ().onNextPageRequest (node , (GridQueryNextPageRequest )msg );
2228- else if (msg instanceof GridQueryNextPageResponse )
2230+
2231+ tracebleMsg = true ;
2232+ }
2233+ else if (msg instanceof GridQueryNextPageResponse ) {
22292234 reduceQueryExecutor ().onNextPage (node , (GridQueryNextPageResponse )msg );
2235+
2236+ tracebleMsg = true ;
2237+ }
22302238 else if (msg instanceof GridH2QueryRequest )
22312239 mapQueryExecutor ().onQueryRequest (node , (GridH2QueryRequest )msg );
22322240 else if (msg instanceof GridH2DmlRequest )
@@ -2240,11 +2248,11 @@ else if (msg instanceof GridQueryCancelRequest)
22402248 else
22412249 processed = false ;
22422250
2243- if (processed && log .isDebugEnabled ())
2244- log .debug ("Processed message " + msg . getClass (). getName () + ": " + nodeId + "-> " + ctx . localNodeId () + " " + msg );
2251+ if (processed && log .isDebugEnabled () && (! tracebleMsg || log . isTraceEnabled ()) )
2252+ log .debug ("Processed message: [srcNodeId= " + nodeId + ", msg= " + msg + ']' );
22452253 }
22462254 catch (Throwable th ) {
2247- U .error (log , "Failed to process message: " + msg , th );
2255+ U .error (log , "Failed to process message: [srcNodeId= " + nodeId + ", msg=" + msg + ']' , th );
22482256 }
22492257 }
22502258 finally {
0 commit comments