Apparatus and method to reduce communication traffic in a decentralized processing system of a publish/subscribe model

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.

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.