(exitcode int)
| 32 | } |
| 33 | |
| 34 | func showUsageAndExit(exitcode int) { |
| 35 | usage() |
| 36 | os.Exit(exitcode) |
| 37 | } |
| 38 | |
| 39 | func printMsg(m *nats.Msg, i int) { |
| 40 | log.Printf("[#%d] Received on [%s] Queue[%s] Pid[%d]: '%s'", i, m.Subject, m.Sub.Queue, os.Getpid(), string(m.Data)) |