From 1434ee7da8682a8934785cfeb495c71a2b18c6f4 Mon Sep 17 00:00:00 2001 From: Neil Twigg Date: Wed, 12 Jul 2023 19:52:20 +0100 Subject: [PATCH] More specific check for service imports vs any internal sub Signed-off-by: Neil Twigg --- server/client.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/client.go b/server/client.go index 9d744914..f3752482 100644 --- a/server/client.go +++ b/server/client.go @@ -3127,8 +3127,8 @@ var needFlush = struct{}{} // deliverMsg will deliver a message to a matching subscription and its underlying client. // We process all connection/client types. mh is the part that will be protocol/client specific. func (c *client) deliverMsg(prodIsMQTT bool, sub *subscription, acc *Account, subject, reply, mh, msg []byte, gwrply bool) bool { - // Check sub client and check echo. Only do this if not an internal sub. - if sub.client == nil || (c == sub.client && !sub.client.echo && sub.icb == nil) { + // Check sub client and check echo. Only do this if not a service import. + if sub.client == nil || (c == sub.client && !sub.client.echo && !sub.si) { return false }