Topic-based messaging using consumer address and pool

A computer-implemented method comprising:

• receiving a consumer address of a receiver machine from a configurator machine, the consumer address being unique to the receiver machine within a consumer pool of receiver machines, the consumer pool comprising a plurality of receiver machines to receive messages that correspond to a topic, the consumer address being generated by the configurator machine based on registration data transmitted by the receiver machine, the registration data indicating that the receiver machine is available to receive at least some of the messages that correspond to the topic, at least one of the messages being transmitted by a transmitter machine communicatively coupled to the receiver machine via a network;
• generating a multicast communication based on the consumer address, the multicast communication indicating an availability of the receiver machine to receive at least some of the messages that correspond to the topic, the generating being performed by a module implemented using a processor of the receiver machine;
• transmitting the multicast communication via the network;
• and
• receiving the at least one of the messages that correspond to the topic from the transmitter machine, the at least one of the messages including a message that corresponds to the consumer address of the receiver machine.

A system comprising:

• an identification module to identify a receiver machine as available for inclusion in a consumer pool of receiver machines, the consumer pool comprising a plurality of receiver machines to receive messages that correspond to a topic, at least one of the messages being transmitted from a transmitter machine communicatively coupled to the receiver machine and to each of the plurality of receiver machines via a network;
• a hardware-implemented generation module to generate a consumer address of the receiver machine with respect to the consumer pool, the consumer address being unique to the receiver machine among the plurality of receiver machines within the consumer pool, the generating being based on registration data received from the receiver machine;
• and
• a provision module to provide the consumer address to the receiver machine, the consumer address being usable by the receiver machine to generate a multicast communication based on the consumer address, the multicast communication indicating that the receiver machine is available to receive at least some of the messages that correspond to the topic.

A system comprising:

• a reception module to:
• receive a consumer address of a receiver machine from a configurator machine, the consumer address being unique to the receiver machine within a consumer pool of receiver machines, the consumer pool comprising a plurality of receiver machines to receive messages that correspond to a topic, the consumer address being generated by the configurator machine based on registration data transmitted by the receiver machine, the registration data indicating that the receiver machine is available to receive at least some of the messages that correspond to the topic, at least one of the messages being transmitted by a transmitter machine communicatively coupled to the receiver machine via a network;
• and
• receive the at least one of the messages that correspond to the topic from the transmitter machine, the at least one of the messages including a message that corresponds to the consumer address of the receiver machine;
• a hardware-implemented generation module to generate a multicast communication based on the consumer address, the multicast communication indicating an availability of the receiver machine to receive at least some of the messages that correspond to the topic;
• and
• a transmission module to transmit the multicast communication via the network.

A machine-readable storage medium comprising instructions that, when executed by one or more processors of a machine, cause the machine to perform a method comprising:

• identifying a receiver machine as available for inclusion in a consumer pool of receiver machines, the consumer pool comprising a plurality of receiver machines to receive messages that correspond to a topic, at least one of the messages being transmitted from a transmitter machine communicatively coupled to the receiver machine and to each of the plurality of receiver machines via a network;
• generating a consumer address of the receiver machine with respect to the consumer pool, the consumer address being unique to the receiver machine among the plurality of receiver machines within the consumer pool, the generating being based on registration data received from the receiver machine;
• and
• providing the consumer address to the receiver machine, the consumer address being usable by the receiver machine to generate a multicast communication based on the consumer address, the multicast communication indicating that the receiver machine is available to receive at least some of the messages that correspond to the topic.

A machine-readable storage medium comprising instructions that, when executed by one or more processors of a machine, cause the machine to perform a method comprising:

• receiving a consumer address of a receiver machine from a configurator machine, the consumer address being unique to the receiver machine within a consumer pool of receiver machines, the consumer pool comprising a plurality of receiver machines to receive messages that correspond to a topic, the consumer address being generated by the configurator machine based on registration data transmitted by the receiver machine, the registration data indicating that the receiver machine is available to receive at least some of the messages that correspond to the topic, at least one of the messages being transmitted by a transmitter machine communicatively coupled to the receiver machine via a network;
• generating a multicast communication based on the consumer address, the multicast communication indicating an availability of the receiver machine to receive at least some of the messages that correspond to the topic;
• transmitting the multicast communication via the network;
• and
• receiving the at least one of the messages that correspond to the topic from the transmitter machine, the at least one of the messages including a message that corresponds to the consumer address of the receiver machine.