[go: up one dir, main page]

EP1112645A1 - Mechanism controlling and ordering message propagation - Google Patents

Mechanism controlling and ordering message propagation

Info

Publication number
EP1112645A1
EP1112645A1 EP00953230A EP00953230A EP1112645A1 EP 1112645 A1 EP1112645 A1 EP 1112645A1 EP 00953230 A EP00953230 A EP 00953230A EP 00953230 A EP00953230 A EP 00953230A EP 1112645 A1 EP1112645 A1 EP 1112645A1
Authority
EP
European Patent Office
Prior art keywords
messages
asynchronous
consumer
broker
asynchronous communication
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Withdrawn
Application number
EP00953230A
Other languages
German (de)
French (fr)
Inventor
Laurent Clevy
Michel Ruffin
Simone Sedillot
Ramzi Karoui
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Alcatel Lucent SAS
Original Assignee
Alcatel SA
Nokia Inc
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Alcatel SA, Nokia Inc filed Critical Alcatel SA
Publication of EP1112645A1 publication Critical patent/EP1112645A1/en
Withdrawn legal-status Critical Current

Links

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/10—Flow control; Congestion control
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/10—Flow control; Congestion control
    • H04L47/22—Traffic shaping
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/10—Flow control; Congestion control
    • H04L47/26—Flow control; Congestion control using explicit feedback to the source, e.g. choke packets
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
    • H04L69/24—Negotiation of communication capabilities

Definitions

  • the invention relates to managing the propagation of messages in an asynchronous system.
  • Effective asynchronous communication between message providers and consumer objects generally requires an intermediary object that decouples the communication.
  • Such an intermediary object has the capacity for storing and transferring messages. It is called asynchronous broker
  • the invention consists of a method of asynchronous communication of messages between an ob
  • and consumer of messages defines a set rules regarding the throughput of messages received and specifies it to the asynchronous broker. This definition can be fixed, or redefined dynamically during the various communications For example one can redefine the rules periodically
  • the rules can consist in defining a maximum threshold of messages.
  • the asynchronous broker transmits the information concerning the flow of messages to the consumer.
  • the invention places control at the level of the asynchronous broker, who from this point of view stinks of the role of a scheduler
  • the scheduler must then watch over the application of the time scheduling constraints provided to it by the consumer.
  • a consumer specifies with the scheduler the scheduling rules which fix the debit he wishes to accept.
  • the consumer adjusts the traffic by requesting a change in the scheduling rules.
  • the scheduler may have to retrieve messages directly from the producers.
  • the scheduler orders the broker to memorize the messages on behalf of the registered consumer.
  • the main task of the scheduler is to apply the scheduling rules provided by the consumer, his second task is to measure the state of traffic and provide the corresponding information.
  • the invention is particularly suited to the transactional context.
  • the acceptance of messages in the broker is subject to validation of the transaction which produced them.
  • each decision taken by the latter to transmit messages to the consumer is made consistent with the messages from the suppliers.
  • the decisions made by the scheduler are stored in a secure memory as part of the supplier's transaction. Thus, if the transaction fails, the decision is canceled.
  • the invention makes it possible to guarantee the fluidity of the transmission of messages between suppliers and consumers. As a result, the consumer does not experience sudden changes in traffic. The consumer no longer takes care of the flow control and receives precise information on the traffic allowing him to adjust his rate of reception of the messages.
  • the conventional solution is contained in the invention. It is possible to suspend reception by defining a zero flow and to resume it by modifying said flow.

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Computer And Data Communications (AREA)
  • Communication Control (AREA)

Abstract

The invention concerns an asynchronous message communication between a message providing object and a message consuming object using at least an asynchronous broker between said objects. The invention is characterised in that the message consuming objects defines a set of rules concerning the rate of messages received and specifies it to the asynchronous broker. The invention is particularly applicable in transaction exchanges.

Description

MECANISME DE CONTROLE ET D'ORDONNANCEMENT DE LA PROPAGATION DE MESSAGES. MECHANISM FOR CONTROLLING AND SCHEDULING THE SPREAD OF MESSAGES

L'invention concerne la gestion de la propagation de messages dans un système asynchrone. Une communication asynchrone efficace entre des ob|ets fournisseurs de messages et des ob|ets consommateurs nécessite généralement un ob|et intermédiaire qui découple la communication Un tel ob|et intermédiaire possède les capacités de mémorisation et de transfert de messages. Il est appelé courtier asynchroneThe invention relates to managing the propagation of messages in an asynchronous system. Effective asynchronous communication between message providers and consumer objects generally requires an intermediary object that decouples the communication. Such an intermediary object has the capacity for storing and transferring messages. It is called asynchronous broker

Lorsque l'on transmet des messages sans prendre en considération les capacités de traitement du destinataire, on risque de surcharger celui-ci et de faire baisser ses performances II est alors nécessaire de délivrer les messages en fonction des capacités de traitement du consommateurWhen transmitting messages without taking into account the processing capacity of the recipient, there is a risk of overloading the recipient and lowering his performance. It is then necessary to deliver the messages according to the processing capabilities of the consumer.

Actuellement le seul moyen connu consiste a permettre au consommateur de suspendre la réception des messages et de la reprendre lorsqu'il a retrouvé une capacité de traitement suffisante Cette solution n'est pas satisfaisante car elle exige de la part du consommateur un contrôle instantané du trafic ce qui réduit ses performances. Une alternative a cette solution consiste a effectuer périodiquement le contrôle. Cependant, ceci conduit irrémédiablement à une congestion du trafic chez le consommateur si le trafic s'accroît de manière brusque et imprévisible Dans ce cas, le consommateur surchargé n'est même plus capable de réagir pour interrompre le traficCurrently, the only known means consists in allowing the consumer to suspend the reception of messages and to resume it when he has found sufficient processing capacity. This solution is not satisfactory because it requires from the consumer an instant traffic control. which reduces its performance. An alternative to this solution is to perform the check periodically. However, this leads irreparably to congestion of the traffic at the consumer if the traffic increases in a sudden and unpredictable way In this case, the overloaded consumer is no longer even able to react to interrupt the traffic

L'invention consiste en un procédé de communication asynchrone de messages entre un ob|et fournisseur de messages et un ob|et consommateur de messages utilisant au moins un courtier asynchrone entre lesdits ob|ets L'ob|et consommateur de messages définit un ensemble de règles concernant le débit des messages reçus et le spécifie au courtier asynchrone. Cette définition peut être fixée, ou redéfinie de manière dynamique au cours des différentes communications Par exemple on peut redéfinir les règles périodiquementThe invention consists of a method of asynchronous communication of messages between an ob | and message provider and an ob | and consumer of messages using at least one asynchronous broker between said ob | ets The ob | and consumer of messages defines a set rules regarding the throughput of messages received and specifies it to the asynchronous broker. This definition can be fixed, or redefined dynamically during the various communications For example one can redefine the rules periodically

Les règles peuvent consister a définir un seuil maximal de messages Avantageusement, le courtier asynchrone transmet les informations concernant le débit des messages à l'ob|et consommateurThe rules can consist in defining a maximum threshold of messages. Advantageously, the asynchronous broker transmits the information concerning the flow of messages to the consumer.

Plutôt que de surcharger le consommateur avec la tâche de contrôle du trafic, l'invention place le contrôle au niveau du courtier asynchrone, qui de ce point de vue pue le rôle d'un ordonnanceur L'ordonnanceur doit alors veiller sur l'application des contraintes d'ordonnancement temporelle qui lui sont fournies par le consommateur. Lors de la souscription au courtier asynchrone, un consommateur spécifie auprès de l'ordonnanceur dles règles d'ordonnancement qui fixent le débit qu'il souhaite accepter. Le consommateur ajuste le trafic en demandant un changement dans les règles d'ordonnancement. En cas de baisse du trafic, l'ordonnanceur peut être amené a rapatrier des messages directement à partir des producteurs. En cas d'augmentation du trafic, l'ordonnanceur ordonne le courtier de mémoriser les messages pour le compte du consommateur enregistré.Rather than overloading the consumer with the traffic control task, the invention places control at the level of the asynchronous broker, who from this point of view stinks of the role of a scheduler The scheduler must then watch over the application of the time scheduling constraints provided to it by the consumer. When subscribing to the asynchronous broker, a consumer specifies with the scheduler the scheduling rules which fix the debit he wishes to accept. The consumer adjusts the traffic by requesting a change in the scheduling rules. In the event of a drop in traffic, the scheduler may have to retrieve messages directly from the producers. In the event of an increase in traffic, the scheduler orders the broker to memorize the messages on behalf of the registered consumer.

Ainsi, le consommateur est assuré de recevoir un débit constant.Thus, the consumer is guaranteed to receive a constant flow.

Il est possible de spécifier des règles d'ordonnancement spécifiques pour chaque consommateur.It is possible to specify specific scheduling rules for each consumer.

La tâche principale de l'ordonnanceur consiste à appliquer les règles d'ordonnancement fournies par le consommateur, sa seconde tâche consiste à mesurer l'état du trafic et de fournir les informations correspondantes.The main task of the scheduler is to apply the scheduling rules provided by the consumer, his second task is to measure the state of traffic and provide the corresponding information.

L'invention est particulièrement adaptée au contexte transactionnel . Dans ce contexte, l'acceptation des messages dans le courtier est subordonnée à validation de la transaction qui les a produit.The invention is particularly suited to the transactional context. In this context, the acceptance of messages in the broker is subject to validation of the transaction which produced them.

Afin d'améliorer la fiabilité de l'ordonnanceur, chaque décision prise par ce dernier pour transmettre des messages vers le consommateur est rendue cohérente avec les messages des fournisseurs. Les décisions prises par l'ordonnanceur sont mémorisées dans une mémoire sécurisée en tant que partie de la transaction du fournisseur. Ainsi, si la transaction échoue, la décision est annulée.In order to improve the reliability of the scheduler, each decision taken by the latter to transmit messages to the consumer is made consistent with the messages from the suppliers. The decisions made by the scheduler are stored in a secure memory as part of the supplier's transaction. Thus, if the transaction fails, the decision is canceled.

L'invention permet de garantir la fluidité de la transmission des messages entre fournisseurs et consommateurs. Par conséquent, le consommateur ne subit pas les variations brusques de trafic. Le consommateur ne s'occupe plus du contrôle du flux et reçoit une information précise sur le trafic lui permettant de régler son débit de réception des messages. De plus, la solution classique est contenue dans l'invention. I l est possible de suspendre la réception en définissant un débit nul et de la reprendre en modifiant ledit débit. The invention makes it possible to guarantee the fluidity of the transmission of messages between suppliers and consumers. As a result, the consumer does not experience sudden changes in traffic. The consumer no longer takes care of the flow control and receives precise information on the traffic allowing him to adjust his rate of reception of the messages. In addition, the conventional solution is contained in the invention. It is possible to suspend reception by defining a zero flow and to resume it by modifying said flow.

Claims

REVENDICATIONS 1 - Procédé de communication asynchrone de messages entre un objet fournisseur de messages et un objet consommateur de messages utilisant au moins un courtier asynchrone entre lesdits objets caractérisé en ce que le l'objet consommateur de messages définit un ensemble de règles concernant le débit des messages reçus et le spécifie au courtier asynchrone.1 - Method for asynchronous communication of messages between a message provider object and a message consumer object using at least one asynchronous broker between said objects characterized in that the message consumer object defines a set of rules concerning the throughput of messages received and specifies it to the asynchronous broker. 2 - Procédé de communication asynchrone de messages selon la revendication 1 caractérisé en ce que l'objet consommateur effectue la définition de ses règles de manière dynamique au cours des différentes transactions. 3 - Procédé de communication asynchrone de messages selon la revendication 2 caractérisé en ce que les règles sont redéfinies périodiquement.2 - Method for asynchronous communication of messages according to claim 1 characterized in that the consumer object performs the definition of its rules dynamically during the various transactions. 3 - A method of asynchronous communication of messages according to claim 2 characterized in that the rules are redefined periodically. 4 - Procédé de communication asynchrone de messages selon l'une quelconque des revendications 1 à 3 caractérisé en ce qu'un seuil maximal de messages est défini. 5 - Procédé de communication asynchrone de messages selon l'une quelconque des revendications précédentes caractérisé en ce que le courtier asynchrone transmet les informations concernant le débit des messages à l'objet consommateur.4 - Method for asynchronous communication of messages according to any one of claims 1 to 3 characterized in that a maximum threshold of messages is defined. 5 - Method for asynchronous communication of messages according to any one of the preceding claims, characterized in that the asynchronous broker transmits information concerning the throughput of messages to the consumer object. 6 - Procédé de communication asynchrone de messages selon l'une quelconque des revendications précédentes caractérisé en ce que l'on définit des règles spécifiques pour chaque objet consommateur.6 - Method for asynchronous communication of messages according to any one of the preceding claims, characterized in that specific rules are defined for each consumer object. 7 - Procédé de communication asynchrone de messages dans des échanges transactionnels selon l'une quelconque des revendications précédentes caractérisé en ce que la transmission des messages n'est effectuée qu'après la validation des transactions associées auxdits messages. 7 - Method for asynchronous communication of messages in transactional exchanges according to any one of the preceding claims, characterized in that the transmission of the messages is only carried out after the validation of the transactions associated with the said messages.
EP00953230A 1999-07-15 2000-07-13 Mechanism controlling and ordering message propagation Withdrawn EP1112645A1 (en)

Applications Claiming Priority (3)

Application Number Priority Date Filing Date Title
FR9909190 1999-07-15
FR9909190 1999-07-15
PCT/FR2000/002034 WO2001006715A1 (en) 1999-07-15 2000-07-13 Mechanism controlling and ordering message propagation

Publications (1)

Publication Number Publication Date
EP1112645A1 true EP1112645A1 (en) 2001-07-04

Family

ID=9548139

Family Applications (1)

Application Number Title Priority Date Filing Date
EP00953230A Withdrawn EP1112645A1 (en) 1999-07-15 2000-07-13 Mechanism controlling and ordering message propagation

Country Status (4)

Country Link
EP (1) EP1112645A1 (en)
JP (1) JP2003505932A (en)
AU (1) AU6575600A (en)
WO (1) WO2001006715A1 (en)

Citations (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US5870561A (en) * 1996-03-15 1999-02-09 Novell, Inc. Network traffic manager server for providing policy-based recommendations to clients

Family Cites Families (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
FI955944A (en) * 1995-12-11 1997-06-12 Nokia Telecommunications Oy Data rate matching procedure and data rate matching unit
US5878224A (en) * 1996-05-24 1999-03-02 Bell Communications Research, Inc. System for preventing server overload by adaptively modifying gap interval that is used by source to limit number of transactions transmitted by source to server
AU3782997A (en) * 1996-09-03 1998-03-26 Toyota Jidosha Kabushiki Kaisha Information communication controller and system for the same

Patent Citations (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US5870561A (en) * 1996-03-15 1999-02-09 Novell, Inc. Network traffic manager server for providing policy-based recommendations to clients

Also Published As

Publication number Publication date
JP2003505932A (en) 2003-02-12
WO2001006715A1 (en) 2001-01-25
AU6575600A (en) 2001-02-05

Similar Documents

Publication Publication Date Title
US9560000B2 (en) Reconfiguring an electronic message to effect an enhanced notification
US6055564A (en) Admission control where priority indicator is used to discriminate between messages
US7062530B2 (en) Browser with messaging capability and other persistent connections
US20040267872A1 (en) Provisioning interface
GB2397474A (en) Method of automatically replicating data objects between a mobile device and a server
JP2000090058A (en) Device and method for publication and subscription data processing and computer program product
US11330047B2 (en) Work-load management in a client-server infrastructure
US8271005B2 (en) Mobile communication device and system with limited data transfer
US11093767B1 (en) Selecting interactive options based on dynamically determined spare attention capacity
WO2003049401A1 (en) Network application interface for mobile users
CA3065489A1 (en) Systems and methods for real-time application configuration for nfc transactions
EP0510136B1 (en) Estimative control system for a group of work stations
WO2001006715A1 (en) Mechanism controlling and ordering message propagation
EP3239954A1 (en) Method and system for providing taxi services based on the location of the user and the vehicle
KR20050096058A (en) Schedule management method for mobile station using weather information
US20040177111A1 (en) Non-persistent service support in transactional application support environments
CN110930013A (en) Data processing method, device, server and storage medium
CN114169997A (en) A debit method and device
FR2821226A1 (en) METHOD AND DEVICE FOR SIGNALING A CALL OR MESSAGE TO ITS RECIPIENT
US20060036532A1 (en) Methods and apparatus for executing small size orders
EP1143688A1 (en) Mobile services on the basis of a smart card
CA2428240A1 (en) System and method for interfacing a data processing system to a business-to-business integration system
EP3646191A1 (en) Technologies for managing web notifications in client-server systems
KR20170075968A (en) Apparatus and method for adjusting a transfer limit based on electronic finance using pattern
CA3113170C (en) Method and system for providing access to a node of a shared resource

Legal Events

Date Code Title Description
PUAI Public reference made under article 153(3) epc to a published international application that has entered the european phase

Free format text: ORIGINAL CODE: 0009012

AK Designated contracting states

Kind code of ref document: A1

Designated state(s): AT BE CH CY DE DK ES FI FR GB GR IE IT LI LU MC NL PT SE

AX Request for extension of the european patent

Free format text: AL;LT;LV;MK;RO;SI

17P Request for examination filed

Effective date: 20010725

RAP1 Party data changed (applicant data changed or rights of an application transferred)

Owner name: ALCATEL LUCENT

17Q First examination report despatched

Effective date: 20071217

STAA Information on the status of an ep patent application or granted ep patent

Free format text: STATUS: THE APPLICATION IS DEEMED TO BE WITHDRAWN

18D Application deemed to be withdrawn

Effective date: 20080429