From f973c163215bcd277bce66207bdad4ed6c6cadcc Mon Sep 17 00:00:00 2001 From: postmannen Date: Thu, 17 Mar 2022 04:30:23 +0100 Subject: [PATCH] corrected continues when branching in startupfolder --- README.md | 2 ++ message_readers.go | 3 ++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/README.md b/README.md index 1517ace..1c4f0e5 100644 --- a/README.md +++ b/README.md @@ -415,6 +415,8 @@ Messages can be automatically scheduled to be read and executed at startup of St A folder named **startup** will be present in the working directory of Steward, and you put the messages to be executed at startup here. +Messages put in the startup folder will not be sent to the broker but handled locally, and only (eventually) the reply message from the Request Method called will be sent to the broker. + #### How to send the reply to another node Normally the **fromNode** field is automatically filled in with the node name of the node where a message originated. diff --git a/message_readers.go b/message_readers.go index 2806c8b..977fa21 100644 --- a/message_readers.go +++ b/message_readers.go @@ -104,13 +104,14 @@ func (s *server) readStartupFolder() { if !ok { er := fmt.Errorf("error: subscriberHandler: method type not available: %v", p.subject.Event) p.processes.errorKernel.errSend(p, sams[i].Message, er) + continue } _, err = mh.handler(p, sams[i].Message, s.nodeName) - if err != nil { er := fmt.Errorf("error: subscriberHandler: handler method failed: %v", err) p.processes.errorKernel.errSend(p, sams[i].Message, er) + continue } }