Merge pull request #6 from jozuenoon/set_logs_to_debug

Set logs to debug for publishing messages.

Author: m110

sns/publisher.go

@@ -46,7 +46,7 @@ func (p Publisher) Publish(topic string, messages ...*message.Message) error {
 	}
 
 	for _, msg := range messages {
-		p.logger.Info("Sending message", watermill.LogFields{"msg": msg})
+		p.logger.Debug("Sending message", watermill.LogFields{"msg": msg})
 		_, err = p.sns.Publish(&sns.PublishInput{
 			TopicArn: topicInfo.TopicArn,
 			Message:  aws.String(string(msg.Payload)),

sqs/publisher.go

@@ -54,7 +54,7 @@ func (p Publisher) Publish(topic string, messages ...*message.Message) error {
 			return err
 		}
 
-		p.logger.Info("Sending message", watermill.LogFields{"msg": msg})
+		p.logger.Debug("Sending message", watermill.LogFields{"msg": msg})
 		_, err = p.sqs.SendMessage(&sqs.SendMessageInput{
 			QueueUrl:          result.QueueUrl,
 			MessageAttributes: sqsMsg.MessageAttributes,