handleProxyBroadcast broadcasts a Data, Info or Pres message to sessions attached to this proxy topic.
(msg *ServerComMessage)
| 253 | |
| 254 | // handleProxyBroadcast broadcasts a Data, Info or Pres message to sessions attached to this proxy topic. |
| 255 | func (t *Topic) handleProxyBroadcast(msg *ServerComMessage) { |
| 256 | if t.isInactive() { |
| 257 | // Ignore broadcast - topic is paused or being deleted. |
| 258 | return |
| 259 | } |
| 260 | |
| 261 | if msg.Data != nil { |
| 262 | t.lastID = msg.Data.SeqId |
| 263 | } |
| 264 | |
| 265 | t.broadcastToSessions(msg) |
| 266 | } |
| 267 | |
| 268 | // proxyCtrlBroadcast broadcasts a ctrl command to certain sessions attached to this proxy topic. |
| 269 | func (t *Topic) proxyCtrlBroadcast(msg *ServerComMessage) { |
no test coverage detected