Have resolved the publisher error as was missing the lock = threading.Lock() variable, therefore the lock was skipped during the for loop…
However my message is still only acting as a direct message, not guaranteed and still need to resolve this.
Thank you.