Publish/subscribe message broker for message sequences
View Patent ↗A method of operating a publish/subscribe message broker. A method in accordance with an embodiment includes receiving a message on a topic from a publisher, identifying the message as a start of a sequence of messages, transmitting the message to one or more existing subscribers to the topic, registering a new subscriber to the topic, receiving a further message on the topic from a publisher, and transmitting the further message to the one or more existing subscribers to the topic, but not to the registered new subscriber to the topic. Following the identifying of the message as a start of a sequence of messages, the message broker creates a new sub-topic corresponding to the sequence of messages and subscribes the one or more existing subscribers to the new topic. Any new messages received that relate to the sequence are published to the sub-topic and not the original topic. Any new subscribers to the topic are not subscribed to the sub-topic.
1. A method of operating a publish/subscribe message broker comprising:
receiving a message on a topic from a publisher;
identifying the message as a start of a sequence of messages;
transmitting the message to one or more existing subscribers to the topic; and
transmitting, in response to a new subscriber registering to the topic and a further message associated with the sequence being received on the topic from a publisher, the further message to the one or more existing subscribers to the topic, but not to the registered new subscriber to the topic.
2. The method according to claim 1 , wherein
the message is identified as the start of the sequence of messages based upon content of the message.
3. The method according to claim 1 , further comprising:
receiving a yet further message on the topic,
identifying the yet further message as an end of the sequence of messages, and
transmitting each further message on the topic not associated with the sequence to
the one or more existing subscribers to the topic, and to
the registered new subscriber to the topic.
4. The method according to claim 1 , further comprising:
creating, in response to receiving a message not associated with the sequence, a new topic associated with the message not associated with the sequence and
subscribing the new subscriber to the new topic.
5. The method according claim 1 , further comprising:
following identifying the message as a start of a sequence of messages,
creating a new topic corresponding to the sequence of messages and
subscribing the one or more existing subscribers to the new topic.
6. The method according to claim 4 , further comprising:
determining, for a message received on the topic, whether to publish the message on the topic or on the new topic.
7. A publish/subscribe message broker arranged to:
receive a message on a topic from a publisher;
identify the message as a start of a sequence of messages;
transmit the message to one or more existing subscribers to the topic; and
transmit, in response to a new subscriber registering to the topic and in response to receiving on the topic from a publisher a further message associated with the sequence, the further message to the one or more existing subscribers to the topic, but not to the registered new subscriber to the topic.
8. The message broker according to claim 7 , wherein
the message is identified as the start of the sequence of messages based upon content of the message.
9. The message broker according to claim 7 , wherein
the message broker is further arranged to receive a yet further message on the topic, to identify the yet further message as an end of the sequence of messages, and to transmit each further message not associated with the sequence on the topic to the one or more existing subscribers to the topic, and to the registered new subscriber to the topic.
10. The method according to claim 7 , wherein
the message broker is further arranged to create, in response to receiving a message not associated with the sequence, a new topic associated with the message not associated with the sequence and subscribe the new subscriber to the new topic.
11. The message broker according to claim 7 , wherein
the message broker is arranged, following the identifying of the message as a start of a sequence of messages, to create a new topic corresponding to the sequence of messages and to subscribe the one or more existing subscribers to the new topic.
12. The message broker according to claim 10 , wherein
the message broker is further arranged to determine, for a message received on the topic, whether to publish the message on the topic or on the new topic.
13. A computer program product comprising a computer readable storage medium having stored therein computer usable program code for operating a publish/subscribe message broker, the computer usable program code, which when executed by a computer hardware device, causes the computer hardware device to perform:
receiving a message on a topic from a publisher;
identifying the message as a start of a sequence of messages;
transmitting the message to one or more existing subscribers to the topic; and
transmitting in response to a new subscriber registering to the topic and a further message associated with the sequence being received on the topic from a publisher, the further message to the one or more existing subscribers to the topic, but not to the registered new subscriber to the topic.
14. The computer program product according to claim 13 , wherein
the message is identified as the start of the sequence of messages based upon content of the message.
15. The computer program product according to claim 13 , wherein the computer usable program code further causes the computer hardware device to perform:
receiving a yet further message on the topic,
identifying the yet further message as an end of the sequence of messages, and
transmitting each further message not associated with the sequence on the topic to the one or more existing subscribers to the topic, and to the registered new subscriber to the topic.
16. The computer program product according to claim 13 , wherein the computer usable program code further causes the computer hardware device to perform:
creating, in response to receiving a message not associated with the sequence, a new topic associated with the message not associated with the sequence and
subscribing the new subscriber to the new topic.
17. The computer program product according to claim 13 , wherein the computer usable program code further causes the computer hardware device to perform:
following identifying of the message as a start of a sequence of messages,
creating a new topic corresponding to the sequence of messages and
subscribing the one or more existing subscribers to the new topic.
18. The computer program product according to claim 16 , wherein the computer usable program code further causes the computer hardware device to perform:
determining for a message received on the topic, whether to publish the message on the topic or on the new topic.
19. An apparatus for use with a publish/subscribe message broker comprising:
a receiving component for receiving a message on a topic from a publisher;
an identifying component for identifying the message as a start of a sequence of messages;
a first transmitter for transmitting the message to one or more existing subscribers to the topic; and
a second transmitter for transmitting, in response to a new subscriber registering to the topic and in response to receipt on the topic from a publisher of a further message associated with the sequence, the further message to the one or more existing subscribers to the topic, but not to the registered new subscriber to the topic.