Log error type as well
This commit is contained in:
parent
b100f81e0b
commit
9d860d26b6
|
|
@ -354,7 +354,7 @@ func (rpc *AmqpRPCServer) processMessage(msg amqp.Delivery) {
|
|||
return
|
||||
}
|
||||
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))
|
||||
rpc.log.Info(fmt.Sprintf(" [s>][%s][%s] %s failed, replying: %s (%s) [%s]", rpc.serverQueue, msg.ReplyTo, msg.Type, response.Error.Value, response.Error.Type, 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(
|
||||
|
|
|
|||
Loading…
Reference in New Issue