althk / ipmq Goto Github PK

import github.com/althk/ipmq

func main() {
	q := ipmq.New()  // get a new instance of type ipmq.MQ

	someConsumerFn := func(msg ipmq.Msg) error {
		// do something with msg
	}

	cancel, err := q.Register(someConsumerFn)
	if err != nil {
		// registration failed, do something
	}

	// if the consumer needs to unregister
	// simply call cancel
	// cancel()  // unregisters the consumer

	// push a msg to all registered consumers
	q.Push("some msg")  // calls all consumers concurrently

}