build

Documentation

Index

• type DefaultRabbitMQFactory
  • func NewDefaultRabbitMQFactory() *DefaultRabbitMQFactory
• type RabbitMQMessageQueueFactory
  • func NewRabbitMQMessageQueueFactory() *RabbitMQMessageQueueFactory
  • func (c *RabbitMQMessageQueueFactory) Configure(ctx context.Context, config *cconf.ConfigParams)
  • func (c *RabbitMQMessageQueueFactory) CreateQueue(name string) cqueues.IMessageQueue
  • func (c *RabbitMQMessageQueueFactory) SetReferences(ctx context.Context, references cref.IReferences)

Types

type DefaultRabbitMQFactory

type DefaultRabbitMQFactory struct {
	*cbuild.Factory
}

Creates RabbitMQMessageQueue components by their descriptors. See RabbitMQMessageQueue

func NewDefaultRabbitMQFactory

func NewDefaultRabbitMQFactory() *DefaultRabbitMQFactory

NewDefaultRabbitMQFactory method are create a new instance of the factory.

type RabbitMQMessageQueueFactory

type RabbitMQMessageQueueFactory struct {
	*cbuild.Factory
	// contains filtered or unexported fields
}

func NewRabbitMQMessageQueueFactory

func NewRabbitMQMessageQueueFactory() *RabbitMQMessageQueueFactory

func (*RabbitMQMessageQueueFactory) Configure

func (c *RabbitMQMessageQueueFactory) Configure(ctx context.Context, config *cconf.ConfigParams)

func (*RabbitMQMessageQueueFactory) CreateQueue

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

Creates a message queue component and assigns its name.

Parameters:

• name: a name of the created message queue.

func (*RabbitMQMessageQueueFactory) SetReferences

func (c *RabbitMQMessageQueueFactory) SetReferences(ctx context.Context, references cref.IReferences)