KafkaMessageQueueFactory

Creates KafkaMessageQueue components by their descriptors.

Inherits: 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.

public KafkaMessageQueueFactory()

Instance methods

CreateQueue

Creates a message queue component and assigns its name.

public override IMessageQueue CreateQueue(string name)

  • name: string - name of the created message queue.
  • returns: IMessageQueue - created queue component.

See also