Pub/Sub (Publish-Subscribe) v1.6.0+ stable

The publish-subscribe pattern (or pub/sub, for short) is a messaging pattern where senders of messages (publishers), do not program the messages to be sent directly to specific receivers (subscribers). Instead, the programmer “publishes” messages (events), without any knowledge of any subscribers there may be.

Similarly, subscribers express interest in one or more events and only receive messages that are of interest, without any knowledge of any publishers.

image info

Table of Content

Core Features

KubeMQ supports Publish-Subscribe messages patterns with the following core features:

  • Events - An asynchronous real-time Pub/Sub pattern.
  • Events Store - An asynchronous Pub/Sub pattern with persistence.
  • Grouping - Load balancing of events between subscribers
  • Partitioning - Channels/Topics based wildcards


Events are an asynchronous real-time Pub/Sub pattern. In Events, multiple senders can send real-time messages to various receivers; however, only if they are currently connected to KubeMQ; there is no message persistence available in this pattern.

image info

Use Cases

‘Events’ pattern is suitable for cases such as publishing streaming data, logs, notifications, etc.

Demo - Basic


Demo - Group (Load Balancing)


Demo - Wildcards


Events Store

Events Store is an asynchronous Pub/Sub pattern with persistence. In Events Store, multiple senders can send messages to various receivers even if they are not currently. Any receiver can connect to KubeMQ and replay one, any, or all of the messages stored for a specific channel.

image info

Events Store Replay Messages Types

KubeMQ supports six types of Events Store subscriptions and replay:

Type Description
New Events KubeMQ will send only new events
First Event KubeMQ will replay all events from the first stored events, as well as send new events
Last Event KubeMQ will replay the last event and continue to send new events
From Sequence KubeMQ will replay events from a specific sequence and continue to send new events
From Time KubeMQ will replay events from a specific time in the past and continue to send new events
From Time Delta KubeMQ will replay events from the particular time delta back (i.e., 5 min back) and continue to send new events

Start From New Events

image info



Start From First Event

image info



Start From Last Event

image info



Start From Sequence

image info



Start From Time

image info



Start From Time Delta

image info



Grouping - Load Balancing

KubeMQ supports grouping (load balancing) of multiple receivers to share the load


Example 1


Example 2


Example 3


Unique Client ID

The uniqueness of a client ID is essential when using Events Store. At any given time, only one receiver can connect with a unique Client ID. If two receivers try to connect to KubeMQ with the same Client ID, one of them will be rejected.

Client ID and Subscription Types Relations

For each unique Client ID, KubeMQ saves the subscription type in which the client connected; messages can only be replayed once per Client ID and Subscription type.

For example, Receiver with Client ID client-foo-1 subscribes to a channel in First Event mode. They will get all the messages stored in KubeMQ for channel from the first message, and then continue to get new events as they come. If this receiver will disconnect from KubeMQ and re-connect again with any subscription type, only new events in will be delivered for this specific receiver with Client ID client-foo-1.

If a Receiver wishes to receive messages on again, they should subscribe again with a different Client ID than client-foo-1 such client-foo-1-retry.

Use Cases

Events Store pattern is suitable for cases in which events are necessary, such as worker’s pool, chats, and inbox related applications.

Last Updated: 9/20/2019, 1:37:35 PM