Subscriber based priority of messages in a publisher-subscriber domain

Patent metadata

Field	Value
Publication number	US-9497288-B2
Application number	US-201414295372-A
Country	US
Kind code	B2
Filing date	Jun 4, 2014
Priority date	Oct 28, 2013
Publication date	Nov 15, 2016
Grant date	Nov 15, 2016

Abstract

Embodiments of the present invention disclose a method, computer program product, and computer system for prioritizing messages based on subscriber preferences. In an embodiment of the invention, an application server computer determines that a subscriber is subscribed to at least one topic space. The application server computer receives one or more topic priority preferences from the subscriber, and a plurality of messages from the at least one topic space. The application server computer prioritizes the plurality of messages based on the received topic priority preference, and sends the prioritized plurality of messages to the subscriber.

First claim

What is claimed is:

1. A method for prioritizing messages, the method comprising:
receiving, by a message engine, a plurality of messages from a publisher, wherein each message of the plurality of messages correspond to at least one topic space, and comprise a message expiration time and a publisher priority value, and wherein the publisher priority value details an importance level for a corresponding message;
responsive to receiving the plurality of messages from the publisher, prioritizing, by the message engine, the plurality of messages based on the priority value and the corresponding at least one topic space;
determining, by the messaging engine, that a subscriber is subscribed to a topic space corresponding to at least one message of the plurality of messages;
receiving, by the messaging engine, one or more topic priority preferences from the subscriber and an expiration threshold priority setting from the subscriber, wherein the one or more topic priority preferences detail a ranking associated with each topic space, and wherein the expiration threshold priority setting, details a threshold amount of time to increase a priority level of a message;
responsive to receiving one or more topic priority preferences from the subscriber determining, by the message engine, a delivery order of the plurality of messages, wherein the delivery order comprises:
sorting the plurality of messages based on topic space;
identifying at least a first topic space, and a second topic space, wherein the first topic space is a highest ranked topic space and the second topic space is a second highest ranked topic space;
placing a first set of messages that correspond to the first topic space in a first position of a delivery order based on the publisher priority value; and
placing a second set of messages that correspond to the second topic space in a second position of a delivery order based on the publishers priority value; and
sending, by the message engine, the plurality of messages to the subscriber based on the determined delivery order;
determining, by the messaging engine, whether at least one message, of the plurality of messages, is within the expiration threshold priority setting as set by the subscriber, prior to being delivered to the subscriber;
in response to determining that at least one message of the plurality of messages, is within the expiration threshold priority setting, increasing the determined priority of the at least one message by, placing an interrupt to an interrupt vector table ensuing that the at least one message will be delivered prior to the message expiration time; and
responsive to increasing the determined priority of the at least one message, reprioritizing, by the messaging engine, the plurality of messages.

2. The method of claim 1 , wherein the one or more topic priority preferences are received from a subscriber messaging engine.

3. The method of claim 1 , wherein the plurality of messages are received from at least two distinct topic spaces.

4. The method of claim 1 , wherein the plurality of messages are prioritized in a min-heap data structure.

5. The method of claim 1 , wherein at least one topic space of a set of message topics comprise a main message topic and one or more sub message topics.

Assignees

• IBM

Inventors

• Bhat Chethan
• Kesavan Sanjay M
• Lalgowdar Rajesh
• Thyagaraj Lohitashwa

Classifications

• H04L51/26

  Electricity · mapped topic

• H04L67/322 Primary

  Electricity · mapped topic

• H04L51/226 Primary

  Delivery according to priorities · CPC title

• H04L67/61 Primary

  taking into account QoS or priority requirements · CPC title