Message broker system and method

摘要

A message broker system can include a message broker. The message broker can be configured to receive the message instances output as input message instances, store the input message instances in a message store, alter the structure or content of the input message instances according to a message brokering model to generate output message instances and provide output message instances to one or more downstream processors. According to one embodiment, input message stream processing can be decoupled from output message stream processing by the message broker.

主权项

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.