From b100f81e0b1f9110397fd3ba58f43bf86e14e16f Mon Sep 17 00:00:00 2001 From: Roland Shoemaker Date: Tue, 18 Aug 2015 18:57:00 -0700 Subject: [PATCH] Log body at debug --- rpc/amqp-rpc.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/rpc/amqp-rpc.go b/rpc/amqp-rpc.go index 003ce900c..ee134cee6 100644 --- a/rpc/amqp-rpc.go +++ b/rpc/amqp-rpc.go @@ -355,9 +355,8 @@ func (rpc *AmqpRPCServer) processMessage(msg amqp.Delivery) { } if response.Error.Value != "" { rpc.log.Info(fmt.Sprintf(" [s>][%s][%s] %s failed, replying: %s [%s]", rpc.serverQueue, msg.ReplyTo, msg.Type, response.Error.Value, msg.CorrelationId)) - } else { - rpc.log.Info(fmt.Sprintf(" [s>][%s][%s] replying %s(%s) [%s]", rpc.serverQueue, msg.ReplyTo, msg.Type, core.B64enc(jsonResponse), msg.CorrelationId)) } + rpc.log.Debug(fmt.Sprintf(" [s>][%s][%s] replying %s(%s) [%s]", rpc.serverQueue, msg.ReplyTo, msg.Type, core.B64enc(jsonResponse), msg.CorrelationId)) rpc.Channel.Publish( AmqpExchange, msg.ReplyTo,