Skip to content

Commit d34a471

Browse files
committed
Improve logging
1 parent d004845 commit d34a471

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

main.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -208,7 +208,7 @@ func postMessageToExchange(amqpURI string, dirToPost string, newExchange string)
208208
return fmt.Errorf("Publish %s: %s", filePath, err)
209209
}
210210

211-
fmt.Println("Message Published")
211+
fmt.Printf("Message Published:%s\n", filePath)
212212
}
213213

214214
return nil
@@ -361,7 +361,6 @@ func dumpMessagesFromQueue(amqpURI string, queueName string, maxMessages uint, o
361361

362362
if containsNeeded == containsFound {
363363
ackMessage = true
364-
fmt.Printf("Acked msg-%04d\n", messagesReceived)
365364
msgsToAck.Messages = append(msgsToAck.Messages[:i], msgsToAck.Messages[i+1:]...)
366365
break
367366
}
@@ -371,6 +370,7 @@ func dumpMessagesFromQueue(amqpURI string, queueName string, maxMessages uint, o
371370

372371
if ackMessage {
373372
msg.Ack(false)
373+
fmt.Printf("Acked msg-%04d\n", messagesReceived)
374374
}
375375

376376
err = saveMessageToFile(msg, outputDir, messagesReceived, isContentJSON, ackMessage)

0 commit comments

Comments
 (0)