Method of dispatching application messages

摘要

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.

主权项

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.