MCPcopy
hub / github.com/nats-io/nats.go / printMsg

Function printMsg

examples/nats-qsub/main.go:39–41  ·  view source on GitHub ↗
(m *nats.Msg, i int)

Source from the content-addressed store, hash-verified

37}
38
39func 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
43func main() {
44 var urls = flag.String("s", nats.DefaultURL, "The nats server URLs (separated by comma)")

Callers 1

mainFunction · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected