rabbitmq

Documentation

Index

• func TypeNamePB(it proto.Message) string
• type Config
  • func (p *Config) Consume(ctx context.Context, name string, queue string, consumer Consumer) error
  • func (p *Config) ProducePB(ctx context.Context, message proto.Message) error
  • func (p *Config) Publish(ctx context.Context, message proto.Message) error
  • func (p *Config) Url() string
• type Consumer

Functions

func TypeNamePB

func TypeNamePB(it proto.Message) string

Types

type Config

type Config struct {
	Host        string `toml:"host"`
	Port        uint16 `toml:"port"`
	VirtualHost string `toml:"virtual-host"`
	User        string `toml:"user"`
	Password    string `toml:"password"`
}

func (*Config) Consume

func (p *Config) Consume(ctx context.Context, name string, queue string, consumer Consumer) error

func (*Config) ProducePB

func (p *Config) ProducePB(ctx context.Context, message proto.Message) error

https://www.rabbitmq.com/tutorials/tutorial-two-go

func (*Config) Publish

func (p *Config) Publish(ctx context.Context, message proto.Message) error

https://www.rabbitmq.com/tutorials/tutorial-three-go

func (*Config) Url

func (p *Config) Url() string

type Consumer

type Consumer interface {
	Handle(id string, content_type string, body []byte) error
}