Message broker system and method
AssigneeOpen Text Corporation
InventorStefan Daniel Sandberg Cohen
Life of this patent
Estimating the term…
Abstract
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.
Claims21
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.
A method for transforming an input data stream in a first data format to an output data stream of a second format, the method comprising:
- providing a message brokering model;
- receiving a first input data stream;
- receiving a second input data stream;
- in a first job thread:
- identifying events in the first input data stream and generating a first set of message instances comprising data corresponding to the events from the first input data stream;
- providing the first set of message instances to a message broker;
- in a second job thread:
- identifying events in the second input data stream and generating a second set of message instances comprising data corresponding to the events from the second input data stream;
- providing the second set of message instance to the message broker;
- initiating a third thread based on a trigger;
- in the third thread:
- performing, by the message broker, a message alteration on the first set of message instances and second set of message instances message to generate output message instances by editing content of at least one message instance, mapping content from at least one input message instance from a first input message structure associated with a first type of event to an output message structure for the output message instances and concatenating content from first set of message instances with content from the second set of message instances such that the output message instances comprise content from events identified in the first input data stream and content from events identified in the second input data stream;
- generating the output data stream using the output message instances.
Dependencies are inferred from the claim text.