Creates KafkaMessageQueue components by their descriptors.
Implements: MessageQueueFactory
Description
The KafkaMessageQueueFactory class allows you to create KafkaMessageQueue components by their descriptors.
Important points
- The name of created message queue is taken from its descriptor.
Constructors
Creates a new instance of the factory.
KafkaMessageQueueFactory()
Instance methods
create_queue
Creates a message queue component and assigns its name.
create_queue(name: str): IMessageQueue
- name: str - name of the created message queue.
- returns: IMessageQueue - created queue component.