Improved the GCP PubSub bridge to avoid a potential issue where messages could fail to be sent when restarting a node.