Added the ability to create the message, set its correlation id, make sure all services injected in the same call chain get the same correlation id so that messages going across also have the same correlation id.