1. A system of altering message instances comprising: an input port; an output port; a memory; a processor; and a non-transitory computer readable medium storing a set of computer instructions executable by the processor to provide: an input connector to receive input data streams through the input port; an output connector to provide an output data stream through the output port; an event agent configured to identify events in the input data streams and generate input message instances containing data corresponding to the events from the input data streams; a thread job manager configured to receive input message instances from the event agent and pass the input message instances to a message broker, the message broker, configured to: access the message broker model, receive input message instances, store the input message instances in a message store, and generate output message instances according to the message broker model by performing a message alteration task on the input message instances to generate a corresponding output message instance, the message alteration task comprising editing content data from at least one of the input message instances, mapping content data of a first message instance having a first input message structure to an output message structure for the corresponding output message instance; and a process engine configured to execute a process on the output message instances to generate the output data stream based on the output message structure.