PARALLEL MESSAGE PROCESSING ON DIVERSE MESSAGING BUSES

摘要

Systems, methods, and techniques are disclosed for processing messages using a messaging bus. An example system includes an input queue that stores one or more input messages and an output queue that stores one or more output messages. The example system also includes a first service residing in a first messaging bus. In a composite transaction, the first service processes a first message and generates a second message in accordance with processing the first message. The example system further includes a transaction manager that places the second message in the output queue. The second message is routed from the output queue to a second service residing in a second messaging bus for processing, and the first and second messaging buses are diverse. The second service processes, during the composite transaction, the second message.

主权项

1. A system for processing messages using a messaging bus, the system comprising:
an input queue that stores one or more input messages; an output queue that stores one or more output messages; a first service residing in a first messaging bus and coupled to the input queue and the output queue, wherein in a composite transaction, the first service processes a first message of the one or more input messages and generates a second message in accordance with processing the first message; and a transaction manager that places the second message in the output queue, wherein the second message is routed from the output queue to a second service for processing, and wherein the second service resides in a second messaging bus diverse from the first messaging bus and processes, during the composite transaction, the second message.