摘要 |
A method for delivering published messages to subscribers comprises: —storing a set of subscriptions (F1_top1, F2_top3, F3_top4) in a routing table (RTO) of a first broker (BRO), —sending a set of messages (e1, e2, e3) from the first broker (BRO) to a second broker (BR1) according to at least one subscription (F1_top1) stored in the routing table (RTO)1 —receiving a subsequent message (ek), —determining a search term (topi) based on a data element of the subsequent message (ek), —comparing the search term (topi) with a set of data elements stored in a relation repository (CRR), and —controlling sending of the subsequent message (ek) to the second broker (BR1) according to a result of said comparison, wherein the set of data elements stored in the relation repository (CRR) comprises data elements of the messages (e1, e2, e3) previously sent to the second broker (BR1), and wherein said set of subscriptions (F1_top1, F2_top3, F3_top4) contains at least one subscription (F3_top4), which specifies a topic (top4), which is not contained in the set of data elements stored in the relation repository (CRR). |
主权项 |
1. A method, comprising:
causing storage of a set of subscriptions in a routing table of a first broker, causing sending of a set of messages from the first broker to a second broker according to at least one subscription stored in the routing table, receiving a subsequent message, determining a search term based on a data element of the subsequent message, comparing the search term with a set of data elements stored in an operational memory of a repository, controlling sending of the subsequent message to the second broker according to a result of said comparison, wherein the set of data elements stored in the operational memory of the repository comprises data elements of the messages previously sent to the second broker, and wherein said set of subscriptions contains at least one subscription, which specifies a topic, which is not contained in the set of data elements stored in the operational memory of the repository, and adding a new data point to the operational memory of the repository when the subsequent message has been subscribed by at least one subscriber and no matching data elements are found in the operational memory of the repository. |