rmqconsumer

Documentation

Index

• type Config
• type Handle
• type Option
  • func WithConfig(config *Config) Option
  • func WithHandle(h Handle) Option
• type Options
• type RmqConsumer
  • func NewRmqConsumer(opts ...Option) (RmqConsumer, error)

Types

type Config

type Config struct {
	Uri          string
	Exchange     string
	ExchangeType string
	Queue        string
	Tag          string
	RoutingKey   string
}

type Handle

type Handle func(body []byte)

type Option

type Option func(*Options)

func WithConfig

func WithConfig(config *Config) Option

func WithHandle

func WithHandle(h Handle) Option

type Options

type Options struct {
	Handle Handle
	Config *Config
}

type RmqConsumer

type RmqConsumer interface {
	Init(...Option) error
	Options() Options
	Shutdown() error
}

func NewRmqConsumer

func NewRmqConsumer(opts ...Option) (RmqConsumer, error)