dispatcher

Documentation

Index

• type Dispatcher
  • func NewDispatcher(brokerIngressURL, subscriberURL string, requeue bool, maxRetries int, ...) *Dispatcher
  • func (d *Dispatcher) ConsumeFromQueue(ctx context.Context, channel wabbit.Channel, queueName string) error

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(brokerIngressURL, subscriberURL string, requeue bool, maxRetries int, backoffDelay time.Duration, backoffPolicy eventingduckv1.BackoffPolicyType) *Dispatcher

func (*Dispatcher) ConsumeFromQueue

func (d *Dispatcher) ConsumeFromQueue(ctx context.Context, channel wabbit.Channel, queueName string) error

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