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
	SubscriberCACerts string
	MaxRetries        int
	BackoffDelay      time.Duration
	Timeout           time.Duration
	BackoffPolicy     eventingduckv1.BackoffPolicyType
	WorkerCount       int
	Reporter          dispatcher.StatsReporter
	DLX               bool
	DLXName           string
}

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.