Method of dispatching application messages

• US 9,628,386 B2
• Filed: 09/24/2009
• Issued: 04/18/2017
• Est. Priority Date: 09/26/2008
• Status: Expired due to Fees

• Current Assignee: Siemens AG
• Original Assignee: Siemens AG
• Inventors: Bortoloso, Luca Antonio, Giuffrida, Guido, Roncagliolo, Isabella
• Primary Examiner(s): Dollinger, Tonia L
• Assistant Examiner(s): Belani, Kishin G
• Application Number:
  US12/565,921
• Publication Number:
  US 20100082817A1
• Time in Patent Office: 2,763 Days
• Field of Search: 709226
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 47/10 Flow control; Congestion control
• CPC Class Codes: H04L 47/19 at layers above the network layer network arrangements for networked applications for scheduling or organising the servicing of application requests H04L67/60
• CPC Class Codes: H04L 47/20 Traffic policing
• CPC Class Codes: H04L 47/263 Rate modification at the source after receiving feedback
• CPC Class Codes: H04L 47/32 by discarding or delaying data units, e.g. packets or frames
• CPC Class Codes: Y02D 30/50 in wire-line communication networks, e.g. low power modes or reduced link rate

Abstract

A method for dispatching a plurality of messages incoming into a dispatching server, each incoming message being issued by a source application and targeted to at least a destination application, the source application, the destination application and the dispatching server residing within a server-client network. The method includes the steps of defining a maximum rate of incoming messages per second, choosing an appropriate message rate reduction policy out of a first and of a second message rate reduction policy, starting a process which periodically determines a current rate of incoming messages per second, dispatching the message in case the current rate is smaller than the maximum rate, activating the appropriate message rate reduction policy in case the current rate of incoming messages is higher than the maximum rate, monitoring a result of the process and adapting a totality of parameters for the appropriate message rate reduction in case the current rate of incoming messages has dropped below the maximum rate.

Claims

1. A module comprising a user interface, a data communication interface, a network protocol manager, and a message storage entity commonly configured for implementing a method of dispatching a plurality of messages incoming into a dispatching server, each incoming message being issued by a source application and targeted to at least a destination application;

the source application;

the destination application, and the dispatching server residing within a server-client network, the method which comprises the following steps;

a) defining a maximum rate of incoming messages per unit time;

b) choosing a message rate reduction policy;

c) starting a process to periodically determine a current rate of incoming messages per unit time;

d) dispatching the message if the current rate is smaller than a maximum rate;

e) activating the message rate reduction policy if the current rate of incoming messages is higher than the maximum rate, wherein the message rate reduction policy applies a hysteresis mechanism by carrying out the following steps;

i. discarding one of the incoming messages if a priority of the one of the incoming message is lower than a default threshold priority;

ii. notifying the source application about the discarding of the one of the incoming messages and providing to the source application a current message discarding filter;

iii. determining a new current incoming message rate;

iv. checking if the new current rate has decreased below the maximum rate;

v. increasing the default threshold priority to a new threshold priority in case the new current rate is higher than the maximum rate of incoming messages per unit time;

vi. decreasing the new threshold priority in case the new current rate is lower than the maximum rate of incoming messages per unit time;

vii. sending an updated message discarding filter to the source application and restarting at step i; and

f) monitoring a result of the process and adapting a totality of parameters for the message rate reduction in case the current rate of incoming messages has dropped below the maximum rate.

2. The module according to claim 1, further comprising a deployable library containing routines to be embedded in the source application in order to define a required application-side message discarding policy.