pip_services3_kafka.build.KafkaMessageQueueFactory module

class pip_services3_kafka.build.KafkaMessageQueueFactory.KafkaMessageQueueFactory

Bases: pip_services3_messaging.build.MessageQueueFactory.MessageQueueFactory

The KafkaMessageQueueFactory class allows you to create KafkaMessageQueue components by their descriptors.

create_queue(name: str) → pip_services3_messaging.queues.IMessageQueue.IMessageQueue

Creates a message queue component and assigns its name.