(trname string, rxMsg ReceiveMsg)
| 226 | } |
| 227 | |
| 228 | func HandleMsgStream(trname string, rxMsg ReceiveMsg) error { |
| 229 | mm := memsys.ByteMM() |
| 230 | h := &handler{trname: trname, rxMsg: rxMsg, hkName: MsgURLPath(trname), mm: mm} |
| 231 | return h.handle() |
| 232 | } |
| 233 | |
| 234 | func Unhandle(trname string) (err error) { |
| 235 | mu.Lock() |