build

Documentation

Index

• type DefaultMqttFactory
  • func NewDefaultMqttFactory() *DefaultMqttFactory
• type MqttMessageQueueFactory
  • func NewMqttMessageQueueFactory() *MqttMessageQueueFactory
  • func (c *MqttMessageQueueFactory) CreateQueue(name string) cqueues.IMessageQueue

Types

type DefaultMqttFactory

type DefaultMqttFactory struct {
	*cbuild.Factory
}

Creates MqttMessageQueue components by their descriptors. See MqttMessageQueue

func NewDefaultMqttFactory

func NewDefaultMqttFactory() *DefaultMqttFactory

NewDefaultMqttFactory method are create a new instance of the factory.

type MqttMessageQueueFactory

type MqttMessageQueueFactory struct {
	build.MessageQueueFactory
}

MqttMessageQueueFactory are creates MqttMessageQueue components by their descriptors. Name of created message queue is taken from its descriptor.

See Factory See MqttMessageQueue

func NewMqttMessageQueueFactory

func NewMqttMessageQueueFactory() *MqttMessageQueueFactory

NewMqttMessageQueueFactory method are create a new instance of the factory.

func (*MqttMessageQueueFactory) CreateQueue

func (c *MqttMessageQueueFactory) CreateQueue(name string) cqueues.IMessageQueue

Creates a message queue component and assigns its name.

Parameters:

• name: a name of the created message queue.