async

Documentation

Index

• type Dispatcher
  • func NewDispatcher(ch *amqp.Channel) *Dispatcher
  • func (d *Dispatcher) Close()
  • func (d *Dispatcher) Dispatch(ctx context.Context, exchange, routingKey string, msg amqp.Publishing) error

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(ch *amqp.Channel) *Dispatcher

func (*Dispatcher) Close

func (d *Dispatcher) Close()

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(ctx context.Context, exchange, routingKey string, msg amqp.Publishing) error