# US 2019/0320033 A1 · Apparatus and method to reduce communication traffic in a decentralized processing system of a publish/subscribe model > Agents: this data is available as JSON from the patentgrep API and MCP server — see https://patentgrep.com/llms.txt - Number: US 2019/0320033 A1 - Document ID: US20190320033A1 - Status: Published application - Kind: A1 - Application number: 16/377,757 - Filed: 2019-04-08 - Published: 2019-10-17 - Earliest claimed: 2018-04-11 - Assignees: Fujitsu Limited - Applicants: Fujitsu Limited - Inventors: Nami Nagata; Hitoshi UENO - Web page: https://patentgrep.com/patent/US20190320033A1 ## CPC - G06F 9/542: {Event management; Broadcasting; Multicasting; Notifications} - H04L 67/562: Brokering proxy services - H04L 12/2854: {Wide area networks, e.g. public data networks} - H04L 67/12: specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks - H04L 67/55: Push-based network services - G06F: ELECTRIC DIGITAL DATA PROCESSING (computer systems based on specific computational models G06N) - H04L: TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION (arrangements common to telegraphic and telephonic communication H04M) ## Abstract An apparatus includes a memory configured to store a correspondence relationship between a broker arranged in each of two or more bases and a topic of data that is to be transmitted from a publisher to the broker. Upon receiving a message to request data of a first topic from a first subscriber, the apparatus identifies a first broker corresponding to the first topic with reference to the memory, and transfers the received message to the identified first broker. ## Claims ### Claim 1 An information processing device comprising: a memory configured to store a correspondence relationship between a broker arranged in each of two or more bases and a topic of data that is to be transmitted from a publisher to the broker; and a processor coupled to the memory and configured to: upon receiving a message to request data of a first topic from a first subscriber, identify a first broker corresponding to the first topic with reference to the memory, and transfer the received message to the identified first broker. ### Claim 2 (depends on 1) The information processing device of claim 1, wherein upon receiving, from another information processing device arranged in a second base different from a first base in which the information processing device is arranged, an inquiry about a broker that is a transfer destination of a message that requests data of a second topic from a second subscriber of the second base, the processor identifies a second broker corresponding to the second topic with reference to the memory, and transmits a response including an address of the identified second broker to the another information processing device. ### Claim 3 (depends on 1) The information processing device of claim 1, wherein upon receiving, from another information processing device arranged in a second base different from a first base in which the information processing device is arranged, an inquiry about a third broker that is a transfer destination of data from a second subscriber that is a new publisher arranged in the second base, the processor identifies the third broker with reference to the memory, and transmits a response including an address of the identified third broker to the another processing device while registering a correspondence relationship between the third broker and a topic of data from the second publisher in the memory. ### Claim 4 (depends on 3) The information processing device of claim 3, wherein upon receiving, from the another information processing device, a notification indicating that transmission of data from a third publisher of the second base is stopped, the processor deletes a correspondence relationship stored in the memory between a topic of data from the third publisher and brokers. ### Claim 5 (depends on 4) The information processing device of claim 4, wherein the notification is issued when transmission of data from the third publisher is not performed for a specific time period. ### Claim 6 (depends on 1) The information processing device of claim 1, wherein the two or more bases are coupled to each other through a wide area network. ### Claim 7 A non-transitory, computer-readable recording medium having stored therein a program for causing a computer included in an information processing device to execute a process comprising: providing a memory included in the information processing device with information on a correspondence relationship between a broker arranged in each of two or more bases and a topic of data that is to be transmitted from a publisher to the broker; upon receiving a message to request data of a first topic from a first subscriber, identify a first broker corresponding to the first topic with reference to the memory; and transferring the received message to the identified first broker. ### Claim 8 A decentralized processing system comprising: a plurality of edge devices each including a first processor; and an information processing device including a memory and a second processor coupled to the memory, wherein the plurality of edge devices include one or more edge devices each including a broker arranged in a second base different from a first base in which the information processing device is arranged; the memory of the information processing device is configured to store a correspondence relationship between a broker arranged in each of two or more bases and a topic of data that is to be transmitted from a publisher to the broker; and the second processor of the information device is configured to: upon receiving a message to request data of a first topic from a first subscriber, identify a first broker corresponding to the first topic with reference to the memory, and transfer the received message to the identified first broker.