Publish subscribe system
First Claim
1. A system of publishing data from a data repository server to a subscribing client, wherein a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, and wherein the filtered data is cached on the selector server and is available for querying by the subscribing client.
0 Assignments
0 Petitions
Accused Products
Abstract
A system of publishing data from a data repository server to a subscribing client, wherein a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, and wherein the filtered data is cached on the selector server and is available for querying by the subscribing client. A number of analytical engines are provided and a broker framework receives requests for an analysis of data and selects one or more engines to use in carrying out the requested analysis. Checkpoints are used to ensure consistency of data.
-
Citations
22 Claims
- 1. A system of publishing data from a data repository server to a subscribing client, wherein a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, and wherein the filtered data is cached on the selector server and is available for querying by the subscribing client.
-
13. A data repository server for use in a publish—
- subscribe system in which data is published from the data repository server to a subscribing client, a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, and in which the filtered data is cached on the selector server and is available for querying by the subscribing client;
wherein the data repository server is configured to publish data change events, to maintain a history of data change events and to re-transmit a set of data change events which have occurred after a specified point, in response to a request from the selector server.
- subscribe system in which data is published from the data repository server to a subscribing client, a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, and in which the filtered data is cached on the selector server and is available for querying by the subscribing client;
-
14. Computer software in the form of machine readable code on a data carrier which when run on data processing apparatus will configure the data processing apparatus as a data repository server for use in a publish—
- subscribe system in which data is published from the data repository server to a subscribing client, a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, and in which the filtered data is cached on the selector server and is available for querying by the subscribing client;
wherein the computer software further configures the data repository server to publish data change events, to maintain a history of data change events and to re-transmit a set of data change events which have occurred after a specified point, in response to a request from the selector server.
- subscribe system in which data is published from the data repository server to a subscribing client, a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, and in which the filtered data is cached on the selector server and is available for querying by the subscribing client;
- 15. A selector server for use in a system in which data is published from a data repository server to a subscribing client, wherein the selector server is configured as a subscribing selector server to receive data published by the data repository server, to filter the data in accordance with filtering criteria defined on the selector server, to re-publish the filtered data to a subscribing client, and to cache the filtered data so that it is available for querying by the subscribing client.
-
18. Computer software in the form of machine readable code on a data carrier which when run on data processing apparatus will configure the data processing apparatus as a selector server for use in a system in which data is published from a data repository server to a subscribing client, wherein the computer software configures the selector server as a subscribing selector server to receive data published by the data repository server, to filter the data in accordance with filtering criteria defined on the selector server, to re-publish the filtered data to a subscribing client, and to cache the filtered data so that it is available for querying by the subscribing client.
-
19. An application server for use in a publish—
- subscribe system in which data is published from a data repository server to a subscribing client, a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, in which the filtered data is cached on the selector server and is available for querying by the subscribing client; and
in which the data repository server is configured to publish data change events, to maintain a history of data change events and to re-transmit a set of data change events which have occurred after a specified point, in response to a request from the selector server;
wherein the application server is configured to receive filtered data re-published by the selector server and also to receive data change events re-published by the selector server, the application server hosting an application which provides information derived from the received filtered data for display to a client, and being further configured so that on notification of a data change event from the selector server, updated data in accordance with the change event is transmitted from the application server to the client.
- subscribe system in which data is published from a data repository server to a subscribing client, a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, in which the filtered data is cached on the selector server and is available for querying by the subscribing client; and
-
20. Computer software in the form of machine readable code on a data carrier which when run on data processing apparatus will configure the data processing apparatus as an application server for use in a publish—
- subscribe system in which data is published from a data repository server to a subscribing client, a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, in which the filtered data is cached on the selector server and is available for querying by the subscribing client; and
in which the data repository server is configured to publish data change events, to maintain a history of data change events and to re-transmit a set of data change events which have occurred after a specified point, in response to a request from the selector server;
wherein the computer software configures the data processing apparatus to receive filtered data re-published by the selector server and also to receive data change events re-published by the selector server;
to host an application which provides information derived from the received filtered data for display to a client; and
, on notification of a data change event from the selector server, to transmit updated data in accordance with the change event from the application server to the client.
- subscribe system in which data is published from a data repository server to a subscribing client, a subscribing selector server receives data published by the data repository server, filters the published data in accordance with filtering criteria defined on the selector server, and re-publishes the filtered data to the subscribing client, in which the filtered data is cached on the selector server and is available for querying by the subscribing client; and
-
21. A system of publishing data change events from a plurality of data repository servers to a subscribing client, wherein a subscribing selector server receives data published by the data repository servers and re-publishes the data change events to the subscribing client, and wherein there is provided a checkpoint server which transmits checkpoints to each of the data repository servers at intervals, each data repository server being configured to publish a checkpoint event on receipt of a checkpoint from the checkpoint server, the receipt of a checkpoint event from one data repository server causing the selector server to queue data change events until a corresponding checkpoint event has been received from each of the data repository servers from which the selector server receives data, after which processing of the queued data change events takes place and the data change events are re-published to the subscribing client.
-
22. A system for analysing data published from a data repository server to a subscribing client, wherein an analytics server provides a plurality of analytics engines which provide calculation based services to the client, there being a broker framework which receives requests for calculations on data and determines which of the analytics engines should be used for a particular request.
Specification