Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DefaultMqttFactory ¶
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.
Click to show internal directories.
Click to hide internal directories.