diff options
| -rw-r--r-- | bookpipeline/cmd/bookpipeline/main.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/bookpipeline/cmd/bookpipeline/main.go b/bookpipeline/cmd/bookpipeline/main.go index f8b0b68..de9b072 100644 --- a/bookpipeline/cmd/bookpipeline/main.go +++ b/bookpipeline/cmd/bookpipeline/main.go @@ -319,7 +319,7 @@ func processBook(msg bookpipeline.Qmsg, conn Pipeliner, process func(chan string // check whether we're using a newer msg handle select { - case m, ok := <-msgc : + case m, ok := <-msgc: if ok { msg = m conn.GetLogger().Println("Using new message handle to delete message from old queue") |