I was able to get this working using the bootstrap method to initialize the connection to Nats. Likewise listening and publishing events on entity actions through the models. It works similarly to socket.io implementations. For anyone that needs to do something similar, feel free to dm me.