consumer

Documentation

Index

• type MessageConsumer
  • func NewMessageConsumer(ch *amqp.Channel, messagesModel model.MessagesModel, ...) *MessageConsumer
  • func (c *MessageConsumer) Start(ctx context.Context) error
  • func (c *MessageConsumer) Stop() error

Types

type MessageConsumer

type MessageConsumer struct {
	// contains filtered or unexported fields
}

func NewMessageConsumer

func NewMessageConsumer(
	ch *amqp.Channel,
	messagesModel model.MessagesModel,
	messageSendsModel model.MessageSendsModel,
	templatesModel model.MessageTemplatesModel,
	settingsModel model.NotificationSettingsModel,
) *MessageConsumer

func (*MessageConsumer) Start

func (c *MessageConsumer) Start(ctx context.Context) error

func (*MessageConsumer) Stop

func (c *MessageConsumer) Stop() error