(updates waveobj.UpdatesRtnType)
| 239 | } |
| 240 | |
| 241 | func (b *BrokerType) SendUpdateEvents(updates waveobj.UpdatesRtnType) { |
| 242 | for _, update := range updates { |
| 243 | b.Publish(WaveEvent{ |
| 244 | Event: Event_WaveObjUpdate, |
| 245 | Scopes: []string{waveobj.MakeORef(update.OType, update.OID).String()}, |
| 246 | Data: update, |
| 247 | }) |
| 248 | } |
| 249 | } |
| 250 | |
| 251 | func (b *BrokerType) getMatchingRouteIds(event WaveEvent) []string { |
| 252 | b.Lock.Lock() |
no test coverage detected