TRANSACTIONAL MESSAGING SUPPORT IN CONNECTED MESSAGING NETWORKS

• US 20180321968A1
• Filed: 07/17/2018
• Published: 11/08/2018
• Est. Priority Date: 11/24/2010
• Status: Active Grant

• Current Assignee: Snap, Inc.
• Original Assignee: Snap, Inc.
• Inventors: Levell, Jonathan, Peel, Matthew David
• Granted Patent: US 10,922,127 B2
• Time in Patent Office: Days
• CPC Class Codes: G06F 2209/544 Remote
• CPC Class Codes: G06F 2209/547 Messaging middleware
• CPC Class Codes: G06F 9/466 Transaction processing
• CPC Class Codes: G06F 9/541 via adapters, e.g. between incompatible applications
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

A method and system are provided for transactional messaging support in connected messaging networks. A first messaging network is provided which does not support transactional processing and a second messaging network is provided which does support transactional processing. A proxy application is provided between the first and second messaging networks. The proxy application receives messages from a first application on the first messaging network, the messages including instructions regarding transactional processing of the messages, and forwards the messages to the second messaging network using a transactional processing supported by the second messaging network.

Claims

1-27. -27. (canceled)

28. A method for transactional messaging support in connected messaging networks, the method comprising:

receiving, at a computing system comprising a proxy application operating between a first messaging network which does not support transactional processing, and a second messaging network which does support transactional processing, a message from a first application on the first messaging network comprising instructions to use advanced features supported by the second messaging network on behalf of the first application;

reading the message to obtain instructions from the first application regarding transactional processing supported by the second messaging network for the message;

wherein the message is one of a plurality of messages representing a first transaction and the instructions for transactional processing of the message include exposing a beginning and an end of the plurality of messages so that the first application has control;

adding, by the computing system, the transactional processing to the message according to the instructions of the first application obtained from the message; and

forwarding, by the computing system, to the second messaging network, the message with the transactional processing for the advanced features supported by the second messaging network.

29. The method of claim 28, wherein the instructions of the first application obtained from the message further comprise additional instructions regarding functional processing of the message, and the method further comprises:

converting the message to include additional functionality supported by the second messaging network, based on the additional instructions regarding functional processing of the message.

30. The method as claimed in claim 29, wherein the additional functionality includes converting a publish/subscribe message to a point to point message.

31. The method as claimed in claim 29, wherein the additional functionality includes converting multiple short messages to a single long message.

32. The method as claimed in claim 29, wherein the additional functionality includes converting a message to a multicast message.

33. The method as claimed in claim 28, wherein the instructions for transactional processing are provided in a header of the message.

34. The method as claimed in claim 28, wherein the instructions for transactional processing are provided in a topic of the message.

35. The method as claimed in claim 28, wherein the proxy application subscribes to messages on a topic on which commands from the first application are published.

36. The method as claimed in claim 28, wherein the first messaging network is a lightweight telemetry transfer network and is connected to the second messaging network via a messaging broker.

37. The method as claimed in claim 28, further comprising:

putting the first transaction to a destination queue on the second messaging network.

38. The method as claimed in claim 28 wherein the proxy application gives the first application control of which operations are performed as a transactional unit of work in the second messaging network.

39. The method of claim 28 further comprising:

allowing the first application to control which received messages from the first application are part of a first transaction or part of a second transaction.

40. The method of claim 28 wherein the message includes a header including a destination for the message from the first application, and an identifier indicating that the message is part of a first transaction.

41. The method of claim 28, further comprising:

determining the outcome of the message by determining a success or failure of the message processed on behalf of the first application and generating a commit response; and

returning the outcome of the message to the first application on the first messaging network by sending the generated commit response message to the first application.

42. The method of claim 28 further comprising:

receiving an instruction from the first application to back out the first transaction.

43. A system comprising:

a processor; and

a non-transitory computer readable medium coupled with the processor, the computer readable medium comprising instructions stored thereon that are executable by the processor to cause a computing device to perform operations comprising;

receiving, via a proxy application operating between a first messaging network which does not support transactional processing, and a second messaging network which does support transactional processing, a message from a first application on the first messaging network comprising instructions to use advanced features supported by the second messaging network on behalf of the first application;

reading the message to obtain instructions from the first application regarding transactional processing supported by the second messaging network for the message;

wherein the message is one of a plurality of messages representing a first transaction and the instructions for transactional processing of the message include exposing a beginning and an end of the plurality of messages so that the first application has control;

adding the transactional processing to the message according to the instructions of the first application obtained from the message; and

forwarding to the second messaging network, the message with the transactional processing for the advanced features supported by the second messaging network.

44. The system of claim 43, wherein the instructions of the first application obtained from the message further comprise additional instructions regarding functional processing of the message, and the method further comprises:

converting the message to include additional functionality supported by the second messaging network, based on the additional instructions regarding functional processing of the message.

45. The system of claim 43, wherein reading the message to obtain instructions from the first application for transactional processing of the message includes reading a header of the message to obtain the instructions.

46. The system of claim 43, wherein reading the message to obtain instructions from the first application for transactional processing of the message includes reading a topic of the message to obtain the instructions.

47. A non-transitory computer readable medium comprising instructions stored thereon that are executable by at least one processor to cause a computing device to perform operations comprising:

receiving, via a proxy application operating between a first messaging network which does not support transactional processing, and a second messaging network which does support transactional processing, a message from a first application on the first messaging network comprising instructions to use advanced features supported by the second messaging network on behalf of the first application;

reading the message to obtain instructions from the first application regarding transactional processing supported by the second messaging network for the message;

wherein the message is one of a plurality of messages representing a first transaction and the instructions for transactional processing of the message include exposing a beginning and an end of the plurality of messages so that the first application has control;

adding the transactional processing to the message according to the instructions of the first application obtained from the message; and

forwarding to the second messaging network, the message with the transactional processing for the advanced features supported by the second messaging network.