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 an input data stream; an output connector to provide an output data stream; an event agent configured to identify events in the input data stream streams and output message instances containing data corresponding to the events from the input data streams according to a message model; a message broker configured to: access a message broker model; receive the message instances; store the input message instances in a message store; generating output message instances according to the message broker model, said generating output message instances comprising performing a message alteration task on a set of input message instances to generate a corresponding output message instance, the message alteration task comprising editing content data from at least one of the set of 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 concatenating content data from input message instances created from a first data stream and a second data stream; a thread job manager configured to receive message instances from the event agent and pass the message instances to the message broker; a process engine configured to execute a process configured for the output message structure on the output message instances to generate the output data stream.