Skip to content

Commit

Permalink
[TOREE-540] Remove accident debugging changes (#206)
Browse files Browse the repository at this point in the history
  • Loading branch information
pan3793 authored Aug 6, 2023
1 parent 5f3e016 commit fb8368b
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down Expand Up @@ -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
Expand Down

0 comments on commit fb8368b

Please sign in to comment.