must goroutine safe
(msg interface{}, userData interface{})
| 3 | type Processor interface { |
| 4 | // must goroutine safe |
| 5 | Route(msg interface{}, userData interface{}) error |
| 6 | // must goroutine safe |
| 7 | Unmarshal(data []byte) (interface{}, error) |
| 8 | // must goroutine safe |