build

Documentation

Index

• type DefaultMessagingFactory
  • func NewDefaultMessagingFactory() *DefaultMessagingFactory
• type IMessageQueueFactory
• type MemoryMessageQueueFactory
  • func NewMemoryMessageQueueFactory() *MemoryMessageQueueFactory
  • func (c *MemoryMessageQueueFactory) CreateQueue(name string) queues.IMessageQueue
• type MessageQueueFactory
  • func InheritMessageQueueFactory() *MessageQueueFactory
  • func (c *MessageQueueFactory) Configure(config *cconf.ConfigParams)
  • func (c *MessageQueueFactory) SetReferences(references cref.IReferences)

Types

type DefaultMessagingFactory

type DefaultMessagingFactory struct {
	cbuild.Factory
}

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(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(config *cconf.ConfigParams)

func (*MessageQueueFactory) SetReferences

func (c *MessageQueueFactory) SetReferences(references cref.IReferences)