This is an automated email from the ASF dual-hosted git repository. aradzinski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-nlpcraft.git
commit a1d0802dde2098358dadf889eb9c4df788fe2f8c Author: Aaron Radzinski <[email protected]> AuthorDate: Sun Sep 27 20:43:02 2020 -0700 Update NCCommandManager.scala --- .../scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala b/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala index 956caf9..7742287 100644 --- a/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala +++ b/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala @@ -64,7 +64,9 @@ object NCCommandManager extends NCService { * @param msg Server message to process. * @param parent Optional parent span. */ - def processServerMessage(msg: NCProbeMessage, parent: Span = null): Unit = + def processServerMessage(msg: NCProbeMessage, parent: Span = null): Unit = { + require(isStarted) + startScopedSpan("processServerMessage", parent, "msgType" → msg.getType, "srvReqId" → msg.dataOpt[String]("srvReqId").getOrElse(""), @@ -134,4 +136,5 @@ object NCCommandManager extends NCService { case e: Throwable ⇒ U.prettyError(logger, s"Error while processing server message (ignoring): ${msg.getType}", e) } } + } }
