Is it possible that the client disconnect/reconnects and the subcription is lost?
Should I be adding .addConnectedListener() to handle the subscribe operation to ensure the subscription is maintained?
Edit: FWIW I tried this, and seems the connection isn’t being dropped, as addConnectedListener is only triggered once.