code: func AmqpProvider(provider Amqp) Option {
  	return func(r *Rabbus) error {
  		if provider != nil {
  			r.Amqp = provider
  			return nil
  		}
  		return errors.New("unexpected amqp provider")
  	}
  }
docs: // AmqpProvider expose a interface for interacting with amqp broker