Parallel message processing on diverse messaging buses

A method of processing messages using a messaging bus, the method comprising:

• processing, by a first service residing in a first messaging bus, a first message from an input queue;
• generating a second message in accordance with processing the first message;
• placing the second message in an output queue, wherein the second message is routed from the output queue to a second service for processing, wherein the second service resides in a second messaging bus diverse from the first messaging bus, and wherein a composite transaction includes a first sub-transaction and a second sub-transaction, and in the composite transaction, the first service processes the first message and the second service processes the second message;
• subscribing, by a first transaction manager, the first service to a topic queue that accepts subscriptions from a plurality of services residing on diverse messaging buses;
• subscribing, by a second transaction manager, the second service to the topic queue;
• in response to successful processing of the first message, committing the first sub-transaction and publishing to the topic queue a third message indicating that the first service has committed the first sub-transaction;
• and
• in response to receiving the third message indicating that the first sub-transaction has been committed and in response to successful processing of the second message, sending, by the second transaction manager, an indication to the second service to commit the second sub-transaction.

A non-transitory machine-readable medium comprising a plurality of machine-readable instructions that when executed by one or more processors is adapted to cause the one or more processors to perform a method comprising:

• processing, by a first service residing in a first messaging bus, a first message from an input queue;
• generating a second message in accordance with processing the first message;
• placing the second message in an output queue, wherein the second message is routed from the output queue to a second service for processing, wherein the second service resides in a second messaging bus diverse from the first messaging bus, and wherein in a composite transaction includes a first sub-transaction and a second sub-transaction, and in the composite transaction, the first service processes the first message and the second service processes the second message;
• subscribing, by a first transaction manager, the first service to a topic queue that accepts subscriptions from a plurality of services residing on diverse messaging buses;
• subscribing, by a second transaction manager, the second service to the topic queue;
• in response to successful processing of the first message, committing the first sub-transaction and publishing to the topic queue a third message indicating that the first service has committed the first sub-transaction;
• and in response to receiving the third message indicating that the first sub-transaction has been committed and in response to successful processing of the second message, sending, by the second transaction manager, an indication to the second service to commit the second sub-transaction.