Update logs for route consuming

cosminrentea · Mar 16, 2017 · 2b2b455 · 2b2b455
1 parent fb86eec
commit 2b2b455
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/server/router/route.go b/server/router/route.go
@@ -271,6 +271,8 @@ func (r *Route) consume() {
 		)
 
 		for {
+			r.logger.WithField("size", r.queue.size()).Debug("Queue size")
+
 			if r.isInvalid() {
 				r.logger.Debug("Stopping to consume because route is invalid.")
 				mTotalDeliverMessageErrors.Add(1)
@@ -289,7 +291,10 @@ func (r *Route) consume() {
 			}
 
 			if err = r.send(msg); err != nil {
-				r.logger.WithField("message", msg).Error("Error sending message through route")
+				r.logger.WithFields(log.Fields{
+					"message": msg,
+					"error":   err.Error(),
+				}).Error("Error sending message through route")
 				if err == errTimeout || err == ErrInvalidRoute {
 					// channel been closed, ending the consumer
 					return