mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-01-08 05:09:15 +00:00
Code Activity

debug, removed sending to errorkernel when checking for method existence

Browse source
This commit is contained in:
postmannen 2024-11-24 22:32:47 +01:00
parent ddb8709797
commit eca56dcc2f
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
server.go
View file

@ -443,7 +443,7 @@ func (s *server) directSAMSChRead() {
// fmt.Printf(" * DEBUG: directSAMSChRead: <- sams = %v\n", sams) // fmt.Printf(" * DEBUG: directSAMSChRead: <- sams = %v\n", sams)
// Range over all the sams, find the process, check if the method exists, and // Range over all the sams, find the process, check if the method exists, and
// handle the message by starting the correct method handler. // handle the message by starting the correct method handler.
for i, sam := range sams { for i := range sams {
processName := processNameGet(sams[i].Subject.name(), processKindSubscriberNats) processName := processNameGet(sams[i].Subject.name(), processKindSubscriberNats)
s.processes.active.mu.Lock() s.processes.active.mu.Lock()
@ -455,8 +455,8 @@ func (s *server) directSAMSChRead() {
mh, ok := p.methodsAvailable.CheckIfExists(sams[i].Message.Method) mh, ok := p.methodsAvailable.CheckIfExists(sams[i].Message.Method)
if !ok { if !ok {
er := fmt.Errorf("error: subscriberHandler: method type not available: %v", p.subject.Method) fmt.Printf("error: subscriberHandler: method type not available: %v", p.subject.Method)
p.errorKernel.errSend(p, sam.Message, er, logError) // p.errorKernel.errSend(p, sam.Message, er, logError)
continue continue
} }