(m *nats.Msg, i int)
| 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)) |
| 41 | } |
| 42 | |
| 43 | func main() { |
| 44 | var urls = flag.String("s", nats.DefaultURL, "The nats server URLs (separated by comma)") |