I need to write tests now to basically produce and consume these events