func (this *EventProcessor) Incoming() chan user.IEventStruct { return this.incoming }
(uuid string)
| 83 | //} |
| 84 | |
| 85 | func (this *EventProcessor) getWorkerByUUID(uuid string) (bool, IWorker) { |
| 86 | this.Lock() |
| 87 | defer this.Unlock() |
| 88 | var eWorker IWorker |
| 89 | var found bool |
| 90 | eWorker, found = this.workerQueue[uuid] |
| 91 | if !found { |
| 92 | return false, eWorker |
| 93 | } |
| 94 | return true, eWorker |
| 95 | } |
| 96 | |
| 97 | func (this *EventProcessor) addWorkerByUUID(worker IWorker) { |
| 98 | this.Lock() |