mirror of
				https://github.com/node-red/node-red.git
				synced 2025-03-01 10:36:34 +00:00 
			
		
		
		
	Compare commits
	
		
			3 Commits
		
	
	
		
			310-tour
			...
			protect-ho
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
|  | 742f05f59d | ||
|  | 79db4f8aa1 | ||
|  | f4d7b71984 | 
| @@ -818,6 +818,16 @@ function handlePreRoute(flow, sendEvent, reportError) { | ||||
|     }) | ||||
| } | ||||
|  | ||||
| function deliverMessageToDestination(sendEvent) { | ||||
|     if (sendEvent?.destination?.node) { | ||||
|         try { | ||||
|             sendEvent.destination.node.receive(sendEvent.msg); | ||||
|         } catch(err) { | ||||
|             Log.error(`Error delivering message to node:${sendEvent.destination.node._path} [${sendEvent.destination.node.type}]`) | ||||
|             Log.error(err.stack) | ||||
|         } | ||||
|     } | ||||
| } | ||||
| function handlePreDeliver(flow,sendEvent, reportError) { | ||||
|     // preDeliver - the local router has identified the node it is going to send to. At this point, the message has been cloned if needed. | ||||
|     hooks.trigger("preDeliver",sendEvent,(err) => { | ||||
| @@ -827,15 +837,10 @@ function handlePreDeliver(flow,sendEvent, reportError) { | ||||
|         } else if (err !== false) { | ||||
|             if (asyncMessageDelivery) { | ||||
|                 setImmediate(function() { | ||||
|                     if (sendEvent.destination.node) { | ||||
|                         sendEvent.destination.node.receive(sendEvent.msg); | ||||
|                     } | ||||
|                     deliverMessageToDestination(sendEvent) | ||||
|                 }) | ||||
|             } else { | ||||
|                 if (sendEvent.destination.node) { | ||||
|                     sendEvent.destination.node.receive(sendEvent.msg); | ||||
|  | ||||
|                 } | ||||
|                 deliverMessageToDestination(sendEvent) | ||||
|             } | ||||
|             // postDeliver - the message has been dispatched to be delivered asynchronously (unless the sync delivery flag is set, in which case it would be continue as synchronous delivery) | ||||
|             hooks.trigger("postDeliver", sendEvent, function(err) { | ||||
|   | ||||
		Reference in New Issue
	
	Block a user