code: func (s *StanServer) processMsg(c *channel) {
  	ss := c.ss
  
  	// Since we iterate through them all.
  	ss.RLock()
  	// Walk the plain subscribers and deliver to each one
  	for _, sub := range ss.psubs {
  		s.sendAvailableMessages(c, sub)
  	}
  
  	// Check the queue subscribers
  	for _, qs := range ss.qsubs {
  		s.sendAvailableMessagesToQueue(c, qs)
  	}
  	ss.RUnlock()
  }
docs: // processMsg will process a message, and possibly send to clients, etc.