code: func (c *Client) dispatchMessage(message redis.Message) {
  	if listeners, exists := c.subscribed[message.Channel]; exists {
  		for _, l := range listeners {
  			l.Messages <- message
  		}
  	}
  }
docs: // Takes in a Redis message and sends it out to any "listening" channels.