dispatcher

Documentation

Index

• Constants
• type Dispatcher
  • func (d *Dispatcher) ConsumeFromQueue(ctx context.Context, conn rabbit.RabbitMQConnectionInterface, ...) error

Constants

const (
	ComponentName = "rabbitmq-dispatcher"
)

Types

type Dispatcher

type Dispatcher struct {
	BrokerIngressURL string
	SubscriberURL    string
	MaxRetries       int
	BackoffDelay     time.Duration
	Timeout          time.Duration
	BackoffPolicy    eventingduckv1.BackoffPolicyType
	WorkerCount      int
	Reporter         dispatcher.StatsReporter
}

func (*Dispatcher) ConsumeFromQueue

func (d *Dispatcher) ConsumeFromQueue(ctx context.Context, conn rabbit.RabbitMQConnectionInterface, channel rabbit.RabbitMQChannelInterface, queueName string) error

ConsumeFromQueue consumes messages from the given message channel and queue. When the context is cancelled a context.Canceled error is returned.