rework comments

Signed-off-by: SammyOina <sammyoina@gmail.com>

consumers/tracing/consumers.go

@@ -27,23 +27,23 @@ type tracingMiddlewareBlock struct {
 	tracer        opentracing.Tracer
 }
 
-// NewAsync creates a new traced consumers.Blocking service
+// NewAsync creates a new traced consumers.AsyncConsumer service
 func NewAsync(tracer opentracing.Tracer, consumerAsync consumers.AsyncConsumer) consumers.AsyncConsumer {
 	return &tracingMiddlewareAsync{
 		consumerAsync: consumerAsync,
 		tracer:        tracer,
 	}
 }
 
-// NewBlocking creates a new traced consumers.Blocking service
+// NewBlocking creates a new traced consumers.BlockingConsumer service
 func NewBlocking(tracer opentracing.Tracer, consumerBlock consumers.BlockingConsumer) consumers.BlockingConsumer {
 	return &tracingMiddlewareBlock{
 		consumerBlock: consumerBlock,
 		tracer:        tracer,
 	}
 }
 
-// ConsumeBlocking  traces consume operations for each message.
+// ConsumeBlocking  traces consume operations for message/s consumed.
 func (tm *tracingMiddlewareBlock) ConsumeBlocking(ctx context.Context, messages interface{}) error {
 	var span opentracing.Span
 	switch m := messages.(type) {
@@ -59,7 +59,7 @@ func (tm *tracingMiddlewareBlock) ConsumeBlocking(ctx context.Context, messages
 	return tm.consumerBlock.ConsumeBlocking(ctx, messages)
 }
 
-// ConsumeAsync traces consume operations for each message.
+// ConsumeAsync traces consume operations for message/s consumed.
 func (tm *tracingMiddlewareAsync) ConsumeAsync(ctx context.Context, messages interface{}) {
 	var span opentracing.Span
 	switch m := messages.(type) {