diff options
Diffstat (limited to 'bookpipeline/cmd')
| -rw-r--r-- | bookpipeline/cmd/bookpipeline/main.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/bookpipeline/cmd/bookpipeline/main.go b/bookpipeline/cmd/bookpipeline/main.go index f1309ca..f8b0b68 100644 --- a/bookpipeline/cmd/bookpipeline/main.go +++ b/bookpipeline/cmd/bookpipeline/main.go @@ -322,8 +322,10 @@ func processBook(msg bookpipeline.Qmsg, conn Pipeliner, process func(chan string case m, ok := <-msgc : if ok { msg = m + conn.GetLogger().Println("Using new message handle to delete message from old queue") } default: + conn.GetLogger().Println("Using original message handle to delete message from old queue") } conn.GetLogger().Println("Deleting original message from queue", fromQueue) |