Topic discard indication

• US 9,515,943 B2
• Filed: 01/31/2013
• Issued: 12/06/2016
• Est. Priority Date: 01/31/2013
• Status: Active Grant

• Current Assignee: Solace Corp.
• Original Assignee: Solace Systems, Inc. (United Kingdom)
• Inventors: Buchko, Steve
• Primary Examiner(s): Hussain, Imad
• Application Number:
  US13/754,939
• Publication Number:
  US 20140214977A1
• Time in Patent Office: 1,405 Days
• Field of Search: 370/235, 370/352, 709/206, 709/207
• US Class Current: 1/1
• CPC Class Codes: H04L 12/1859 adapted to provide push services, e.g. data channels
• CPC Class Codes: H04L 12/1868 Measures taken after transmission, e.g. acknowledgments
• CPC Class Codes: H04L 47/22 Traffic shaping
• CPC Class Codes: H04L 47/32 by discarding or delaying data units, e.g. packets or frames
• CPC Class Codes: H04L 51/23 Reliability checks, e.g. acknowledgments or fault reporting

Abstract

In a message delivery system wherein messages having topic portion defining a topic and a body portion containing information relating to the defined topic are delivered to subscribers based on the topics associated with the messages, the messages are placed in a queue for delivery, and in the event of congestion one or more of the messages are replaced with discard indication messages containing the topics associated with the discarded messages without the corresponding body portions.

Claims

1. A method of managing congestion in a message delivery system wherein messages containing a topic portion defining a topic and a body portion containing information relating to the defined topic are delivered to subscribers based on the topics associated with the messages, comprising:

placing the messages in a queue for delivery to downstream equipment;

in the event of congestion in the message delivery system, discarding one or more of said messages in the queue; and

replacing the discarded messages with one or more discard indication messages indicating that one or more of said messages have been discarded, said discard indication messages containing the topics associated with discarded messages without the corresponding body portions, and said discard indication messages being flagged as discard ineligible to prevent their discard by downstream equipment; and

receiving at the downstream delivery equipment discard indication messages;

matching each of the topics contained within said received discard indication messages to subscribers; and

forwarding a copy of the discard indication messages to subscribers that match the topics contained in the discard indication messages.

2. A method as claimed in claim 1, wherein each said discard indication message contains a field indicating the number of messages discarded for the topic contained therein.

4. A method as claimed in claim 1, wherein when any said discard indication messages received at the downstream equipment containing more than one topic match particular subscribes, said discard indication messages are modified prior to delivery to remove any topics not matching the particular subscribers.

3. A method as claimed in 1, further comprising:

receiving discard indication messages at a subscriber, and

determining at the subscriber from the received discard indication messages which topics have discarded messages.

5. A router for use in a message delivery system wherein messages contain a topic portion defining a topic and a body portion containing information relating to the defined topic are delivered to subscribers based on the topics associated with the messages, comprising:

a queue for enqueing received messages for delivery to downstream equipment for delivering the messages to the subscribers; and

a processor configured, in the event of congestion in the message delivery system, to;

discard one or more of said messages from said queue; and

replace the discarded messages with one or more discard indication messages indicating that one or more of said messages have been discarded, said discard indication messages containing topics associated with discarded messages without the corresponding body portions of the messages, and said discard indication messages being flagged as discard ineligible to prevent their discard by the downstream equipment.

8. A router as claimed in claim 5, wherein said processor is configured to populate a field in each said discard indication message with data indicating the number of messages discarded for the topic contained therein.

6. A router as claimed in 5, wherein the downstream equipment comprises local subscribers.

7. A router as claimed in 5, wherein the downstream equipment comprises a downstream message delivery system.

9. A method of managing messages at a downstream delivery system for messages subject to discard by an upstream delivery system, comprising:

receiving at the downstream delivery system discard indication messages indicating that one or more of said messages have been discarded, said discard indication messages containing topics associated with messages discarded by the upstream without corresponding body portions thereof, and said discard indication messages being flagged as discard ineligible;

matching each of the topics contained within said received discard indication messages to subscribers; and

forwarding a copy of the discard indication message to subscribers that match the topics contained in the discard indication messages to notify the subscribers which topics are associated with messages discarded by the upstream delivery system.

10. A method as claimed in claim 9, further comprising receiving discard indication messages at said subscribers that match the topics contained in the discard indication messages, and

determining at the subscribers from the received discard indication messages which topics have discarded messages.

11. A method as claimed in claim 9, wherein when any said discard indication messages received at the downstream delivery system containing more than one topic match particular subscribers, said discard indication messages are modified prior to delivery to remove any topics not matching the particular subscribers.

12. A method as claimed in claim 9, further comprising matching each of the topics contained within said received discard indication messages to one or more further downstream delivery systems attached to subscribers interested in said topics;

and

forwarding a copy of the discard indication messages to said one or more further downstream delivery systems for delivery to said subscribers.

13. A non-transient storage medium storing instructions for managing congestion in a message delivery system wherein messages containing a topic portion defining a topic and a body portion containing information relating to the defined topic are placed in a queue for delivery to downstream equipment for delivering the messages to subscribers based on the topics associated with the messages, said instructions when executed on the processor and in the event of congestion in the message delivery system causing the processor to:

discard one or more of said messages from said queue; and

replace the discarded messages with one or more discard indication messages indicating that one or more of said messages have been discarded, said discard indication messages containing the topics associated with discarded messages without the corresponding body portions of the messages, and said discard indication messages being flagged as discard ineligible to prevent their discard by the downstream equipment.