Controlling congestion in message-oriented middleware
OwnerCesare Placanicainventor
Life of this patent
Estimating the term…
Abstract
A method is disclosed for controlling congestion in message oriented middleware. In an embodiment, the round trip time for transmitting messages through a message oriented middleware server may be estimated. Further, the frequency that messages are transmitted to the server may be adjusted based on the estimated round trip time in order to reduce congestion at the server.
Claims24
A computer-implemented method comprising:
- sending a first plurality of messages to a message oriented middleware (MOM) broker according to a message frequency value;
- obtaining a first message from the MOM broker, the first message comprising one message among the first plurality of messages;
- determining an estimated round trip time for communicating the first message from a message producer to the MOM broker and back to the producer;
- adjusting the message frequency value based on the estimated round trip time;
- wherein the method is performed by one or more processors.
A machine-readable storage medium storing one or more sequences of instructions, when executed by one or more processors, causes performing:
- sending a first plurality of messages to a message oriented middleware (MOM) broker according to a message frequency value;
- obtaining a first message from the MOM broker, the first message comprising one message among the first plurality of messages;
- determining an estimated round trip time for communicating the first message from a message producer to the MOM broker and back to the producer;
- adjusting the message frequency value based on the estimated round trip time.
An apparatus comprising:
- one or more processors;
- a token bucket configured to send a first plurality of messages to a message oriented middleware (MOM) broker according to a message frequency value;
- a controller configured to receive a first message from the MOM broker, the first message comprising one message among the first plurality of messages;
- a change detection filter configured to determine, using the one or more processors, an average round trip time for communicating the first message from a message producer to the MOM broker and back to the producer;
- and
- wherein the controller adjusts the message frequency value based on the average round trip time.
A computer-implemented method comprising:
- sending a first plurality of messages to a message oriented middleware broker according to a message frequency value;
- receiving a second plurality of messages from the broker, the second plurality of messages comprising a subset of the first plurality of messages;
- determining a round trip time estimation for communicating the second plurality of messages from a message producer to the broker and back to the producer,
- wherein determining the round trip time for the second plurality of messages includes estimating the round trip time with a CUSUM Kalman change detection filter;
- adjusting the message frequency value based on the round trip time estimation;
- wherein the method is performed by one or more processors.
A machine-readable storage medium storing one or more sequences of instructions, when executed by one or more processors, causes performing:
- sending a first plurality of messages to a message oriented middleware broker according to a message frequency value;
- receiving a second plurality of messages from the broker, the second plurality of messages comprising a subset of the first plurality of messages;
- determining a round trip time estimation for communicating the second plurality of messages from a message producer to the broker and back to the producer,
- wherein determining the round trip time estimation for the second plurality of messages includes estimating the round trip time with a CUSUM Kalman change detection filter;
- and
- adjusting the message frequency value based on the round trip time estimation.
Dependencies are inferred from the claim text.