Integrated messaging service to enable applications to stream events to Tigris in real-time and directly without introducing another infrastructure component. Enable subscription on these events.