Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DefaultMessagingFactory ¶
DefaultMessagingFactory Creates MemoryMessageQueue components by their descriptors. Name of created message queue is taken from its descriptor.
See Factory See MemoryMessageQueue
func NewDefaultMessagingFactory ¶
func NewDefaultMessagingFactory() *DefaultMessagingFactory
NewDefaultMessagingFactory are create a new instance of the factory.
type IMessageQueueFactory ¶
type IMessageQueueFactory interface {
// Creates a message queue component and assigns its name.
// Parameters:
// - name: a name of the created message queue.
CreateQueue(name string) queues.IMessageQueue
}
Creates message queue componens.
type MemoryMessageQueueFactory ¶
type MemoryMessageQueueFactory struct {
MessageQueueFactory
}
MemoryMessageQueueFactory are creates MemoryMemoryMessageQueue components by their descriptors. Name of created message queue is taken from its descriptor.
See Factory See MemoryMemoryMessageQueue
func NewMemoryMessageQueueFactory ¶
func NewMemoryMessageQueueFactory() *MemoryMessageQueueFactory
NewMemoryMessageQueueFactory method are create a new instance of the factory.
func (*MemoryMessageQueueFactory) CreateQueue ¶
func (c *MemoryMessageQueueFactory) CreateQueue(ctx context.Context, name string) queues.IMessageQueue
Creates a message queue component and assigns its name.
Parameters:
- name: a name of the created message queue.
type MessageQueueFactory ¶
type MessageQueueFactory struct {
build.Factory
Config *cconf.ConfigParams
References cref.IReferences
}
MessageQueueFactory are creates MessageQueue components by their descriptors. Name of created message queue is taken from its descriptor.
See Factory See MessageQueue
func InheritMessageQueueFactory ¶
func InheritMessageQueueFactory() *MessageQueueFactory
NewMessageQueueFactory method creates a new instance of the factory.
func (*MessageQueueFactory) Configure ¶
func (c *MessageQueueFactory) Configure(ctx context.Context, config *cconf.ConfigParams)
func (*MessageQueueFactory) SetReferences ¶
func (c *MessageQueueFactory) SetReferences(ctx context.Context, references cref.IReferences)
Source Files