diff --git a/communication/src/main/scala/org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala b/communication/src/main/scala/org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala index 1ac7f08e..a515e946 100644 --- a/communication/src/main/scala/org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala +++ b/communication/src/main/scala/org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala @@ -64,7 +64,7 @@ class ZeroMQSocketRunnable( */ protected def processOptions(socket: ZMQ.Socket): Unit = { val socketOptionsString = socketOptions.map("\n- " + _.toString).mkString("") - logger.info( + logger.trace( s"Processing options for socket $socketType: $socketOptionsString" ) @@ -103,7 +103,7 @@ class ZeroMQSocketRunnable( */ protected def processNextOutboundMessage(socket: ZMQ.Socket): Boolean = { val message = Option(outboundMessages.poll()) - message.foreach(msg => println(s"send: \n$msg")) + message.foreach(_.send(socket)) message.nonEmpty