code: func (conn *ProtoConnection) Watch(msgClb func(messaging.ProtoMessage), topics ...string) error {
  	return conn.ConsumeTopic(msgClb, topics...)
  }
docs: // Watch is an alias for ConsumeTopic method. The alias was added in order to conform to messaging.Mux interface.