rabbitmq

Documentation

Index

• func NewRabbitMQConnection(cfg *Config) (*amqp.Connection, error)
• type AMQPPublisher
• type Config
  • func (c *Config) AMQPConfig() *Config
• type Publisher
  • func NewPublisher(cfg *Config) (*Publisher, error)
  • func (p *Publisher) Close()
  • func (p *Publisher) GetChannel() *amqp.Channel
  • func (p *Publisher) GetConnection() *amqp.Connection
  • func (p *Publisher) Publish(ctx context.Context, exchange, key string, msg amqp.Publishing) error
  • func (p *Publisher) PublishWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error

Functions

func NewRabbitMQConnection

func NewRabbitMQConnection(cfg *Config) (*amqp.Connection, error)

NewRabbitMQConnection ...

Types

type AMQPPublisher

type AMQPPublisher interface {
	PublishWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
	Publish(ctx context.Context, exchange, key string, msg amqp.Publishing) error
	GetChannel() *amqp.Channel
	GetConnection() *amqp.Connection
	Close()
}

AMQPPublisher ...

type Config

type Config struct {
	URI string `default:"amqp://guest:guest@localhost:5672"`
}

Config for amqp rabbitmq

func (*Config) AMQPConfig

func (c *Config) AMQPConfig() *Config

AMQPConfig ...

type Publisher

type Publisher struct {
	AMQPConn *amqp.Connection
	AMQPChan *amqp.Channel
}

Publisher ...

func NewPublisher

func NewPublisher(cfg *Config) (*Publisher, error)

NewPublisher ...

func (*Publisher) Close

func (p *Publisher) Close()

Close ...

func (*Publisher) GetChannel

func (p *Publisher) GetChannel() *amqp.Channel

func (*Publisher) GetConnection

func (p *Publisher) GetConnection() *amqp.Connection

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, exchange, key string, msg amqp.Publishing) error

Publish ...

func (*Publisher) PublishWithContext

func (p *Publisher) PublishWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

PublishWithContext ...