queue

Documentation

Index

• func TestRabbitMQConnection(config Config) error
• type Config
• type RabbitMQ
  • func NewRabbitMQ(config Config) (*RabbitMQ, error)
  • func NewRabbitTopic(config Config) (*RabbitMQ, error)
  • func (r *RabbitMQ) Close()
  • func (r *RabbitMQ) CloseChannel()
  • func (r *RabbitMQ) CloseConnect()
  • func (r *RabbitMQ) GetChannel() *amqp.Channel
  • func (r *RabbitMQ) Publish(data interface{}) error
  • func (r *RabbitMQ) PublishToTopic(data interface{}, exchangeName, routingKey string) error

Functions

func TestRabbitMQConnection

func TestRabbitMQConnection(config Config) error

TestRabbitMQConnection tries to connect to specified rabbitQM broker

Types

type Config

type Config interface {
	GetHost() string
	GetPort() int
	GetUser() string
	GetPassword() string
	GetDatabase() string
}

Config Interface With Methods to be a database config

type RabbitMQ

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

func NewRabbitMQ

func NewRabbitMQ(config Config) (*RabbitMQ, error)

NewRabbitMQ creates a nem instance on RabbitMQ

func NewRabbitTopic

func NewRabbitTopic(config Config) (*RabbitMQ, error)

func (*RabbitMQ) Close

func (r *RabbitMQ) Close()

Close closes the rabbit connection and the channel

func (*RabbitMQ) CloseChannel

func (r *RabbitMQ) CloseChannel()

CloseChannel closes the rabbit channel

func (*RabbitMQ) CloseConnect

func (r *RabbitMQ) CloseConnect()

CloseConnect closes the rabbit connection

func (*RabbitMQ) GetChannel

func (r *RabbitMQ) GetChannel() *amqp.Channel

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish(data interface{}) error

Publish sends a message to Rabbit queue

func (*RabbitMQ) PublishToTopic

func (r *RabbitMQ) PublishToTopic(data interface{}, exchangeName, routingKey string) error

Publish message to a topic exchange