Searched refs:onConnMessage (Results 1 – 2 of 2) sorted by relevance
112 func (d *consumerConnDelegate) OnMessage(c *Conn, m *Message) { d.r.onConnMessage(c, m) }
651 func (r *Consumer) onConnMessage(c *Conn, msg *Message) { func