MCPcopy
hub / github.com/davyxu/cellnet / RegisterMessage

Method RegisterMessage

proc/msgdispatcher.go:50–61  ·  view source on GitHub ↗
(msgName string, userCallback cellnet.EventCallback)

Source from the content-addressed store, hash-verified

48}
49
50func (self *MessageDispatcher) RegisterMessage(msgName string, userCallback cellnet.EventCallback) {
51 meta := cellnet.MessageMetaByFullName(msgName)
52 if meta == nil {
53 panic("message not found:" + msgName)
54 }
55
56 self.handlerByTypeGuard.Lock()
57 handlers, _ := self.handlerByType[meta.Type]
58 handlers = append(handlers, userCallback)
59 self.handlerByType[meta.Type] = handlers
60 self.handlerByTypeGuard.Unlock()
61}
62
63func NewMessageDispatcher() *MessageDispatcher {
64

Callers 2

serverFunction · 0.80
relay_agentFunction · 0.80

Calls 1

MessageMetaByFullNameFunction · 0.92

Tested by 1

relay_agentFunction · 0.64