rabbitmq

Documentation

Index

• type QueueConsumer
  • func NewQueueConsumer(queueName string, channel *amqp.Channel) QueueConsumer
• type QueueConsumerFactory
  • func NewQueueConsumerFactory(config *config.Controller) (QueueConsumerFactory, error)

Types

type QueueConsumer

type QueueConsumer interface {
	Consume() (<-chan *types.OpenFaaSInvocation, error)
	Stop()
	ListenForErrors() <-chan *amqp.Error
}

QueueConsumer is an Consumer that listens on a specified queue and forwards incoming messages.

func NewQueueConsumer

func NewQueueConsumer(queueName string, channel *amqp.Channel) QueueConsumer

NewQueueConsumer creates a new instance of QueueConsumer and assigns the passed channel to it.

type QueueConsumerFactory

type QueueConsumerFactory interface {
	Build(topic string) (QueueConsumer, error)
}

QueueConsumerFactory will build QueueConsumer for the given topic.

func NewQueueConsumerFactory

func NewQueueConsumerFactory(config *config.Controller) (QueueConsumerFactory, error)

NewQueueConsumerFactory Initializes a new factory using the provided config.