Processing a message received by a message server

Patent metadata

Field	Value
Publication number	US-9954939-B2
Application number	US-201514856783-A
Country	US
Kind code	B2
Filing date	Sep 17, 2015
Priority date	Sep 25, 2014
Publication date	Apr 24, 2018
Grant date	Apr 24, 2018

Abstract

A message server includes a query store for storing query requests, value data for the query requests, and response time data for the query requests. A message is received, a query request is determined from the message and sent to a query server. A timeout period is determined from response time data stored in the query store. If no response to the query request is received within the timeout period, a value is determined from the value data for the query request stored in the query store. Alternatively, if a response to the query request is received within the timeout period, a value is determined from the response, value data for the value is stored in the query store, and response time data is stored in the query store. An action in response to the message is determined and the action is performed.

First claim

What is claimed is:

1. A method of processing a message received by a message server, the method comprising:
receiving a message by the message server, the message server comprising a query store for storing query requests, value data for the query requests, and response time data for the query requests;
based on receiving the message at the message server, filtering the message to determine, by the message server, a query request from the message, the query request being included in the query store;
sending the query request to a query server;
determining a timeout period from the response time data for the query request stored in the query store;
based on no response to the query request being received by the message server within the timeout period, determining a value from the value data for the query request stored in the query store;
based on a response to the query request being received by the message server within the timeout period, determining a value from the response, storing value data for the value determined from the response in the query store, and storing in the query store response time data for a period the response took to be received by the message server;
determining by the message server an action based on the message using the value obtained from the query store or the value determined from the response; and
performing by the message server the action.

2. The method of claim 1 , wherein the query request comprises an asynchronous request.

3. The method of claim 1 , further comprising filtering the message to remove data not used to determine the query request.

4. The method of claim 1 , wherein the timeout period is a minimum period a response to the query request has taken to be received.

5. The method of claim 1 , wherein based on an amount of response time data for the query request stored in the query store being below a predetermined threshold, the timeout period is a default time period.

6. The method of claim 1 , wherein the action is sending a request to another server.

7. A message server for processing a message, comprising:
a processor; and
a query store for storing query requests, value data for the query requests, and response time data for the query requests, wherein the message server is configured to perform a method, the method comprising:
receiving a message by the message server, the message server comprising a query store for storing query requests, value data for the query requests, and response time data for the query requests;
based on receiving the message at the message server, filtering the message to determine, by the message server, a query request from the message, the query request being included in the query store;
sending the query request to a query server;
determining a timeout period from the response time data for the query request stored in the query store;
based on no response to the query request being received by the message server within the timeout period, determining a value from the value data for the query request stored in the query store;
based on a response to the query request being received by the message server within the timeout period, determining a value from the response, storing value data for the value determined from the response in the query store, and storing in the query store response time data for a period the response took to be received by the message server;
determining by the message server an action based on the message using the value obtained from the query store or the value determined from the response; and
performing by the message server the action.

8. The message server of claim 7 , wherein the query request comprises an asynchronous request.

9. The message server of claim 7 , wherein the method further comprises filtering the message to remove data not used to determine the query request.

10. The message server of claim 7 , wherein the timeout period is a minimum period a response to the query request has taken to be received.

11. The message server of claim 7 , wherein based on an amount of response time data for the query request stored in the query store being below a predetermined threshold, the timeout period is a default time period.

12. The message server of claim 7 , wherein the action is sending a request to another server.

13. A computer program product for processing a message, comprising:
a non-transitory computer readable storage medium readable by a processing circuit and storing instructions for execution by the processing circuit for performing a method comprising:
receiving a message by the message server, the message server comprising a query store for storing query requests, value data for the query requests, and response time data for the query requests;
based on receiving the message at the message server, filtering the message to determine, by the message server, a query request from the message, the query request being included in the query store;
sending the query request to a query server;
determining a timeout period from the response time data for the query request stored in the query store;
based on no response to the query request being received by the message server within the timeout period, determining a value from the value data for the query request stored in the query store;
based on a response to the query request being received by the message server within the timeout period, determining a value from the response, storing value data for the value determined from the response in the query store, and storing in the query store response time data for a period the response took to be received by the message server;
determining by the message server an action based on the message using the value obtained from the query store or the value determined from the response; and
performing by the message server the action.

14. The computer program product of claim 13 , wherein the query request comprises an asynchronous request.

15. The computer program product of claim 13 , wherein the method further comprises filtering the message to remove data not used to determine the query request.

16. The computer program product of claim 13 , wherein the timeout period is a minimum period a response to the query request has taken to be received.

17. The computer program product of claim 13 , wherein based on an amount of response time data for the query request stored in the query store being below a predetermined threshold, the timeout period is a default time period.

18. The computer program product of claim 13 , wherein the action is sending a request to another server.

Assignees

• Int Business Machines Cororation
• IBM

Inventors

• Baldwin Timothy J
• Johnson Andrew
• Johnson Peter J
• Xu Fenglian

Classifications

• H04L67/1008 Primary

  based on parameters of servers, e.g. available memory or workload (monitoring of computer activity G06F11/30) · CPC title

• H04L67/1014

  based on the content of a request · CPC title

• G06Q50/00

  Information and communication technology [ICT] specially adapted for implementation of business processes of specific business sectors, e.g. utilities or tourism (healthcare informatics G16H) · CPC title

• G06F16/24552 Primary

  Database cache management · CPC title

• G06Q40/04

  Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange · CPC title