dispatcher

Documentation

Index

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

Constants

const (
	ComponentName = "rabbitmq-dispatcher"
)

Types

type Dispatcher

type Dispatcher struct {
	BrokerIngressURL string
	SubscriberURL    string

	// Upon failure to deliver to sink, should the RabbitMQ messages be requeued.
	// For example, if the DeadLetterSink has been configured, then do not Requeue.
	Requeue bool

	MaxRetries    int
	BackoffDelay  time.Duration
	BackoffPolicy eventingduckv1.BackoffPolicyType
	WorkerCount   int
}

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.