rabbitmq

Documentation

Index

• func ConnectRabbitMQ(username, password, host, vhost string) (*amqp.Connection, error)
• type Event
• type RabbitClient
  • func NewRabbitMQClient(conn *amqp.Connection) (RabbitClient, error)
  • func (rc RabbitClient) Close() error
  • func (rc RabbitClient) Publish(ctx context.Context, event Event) error
  • func (rc RabbitClient) QueueDeclare() (amqp.Queue, error)
  • func (rc RabbitClient) Subscribe(q string) (<-chan amqp.Delivery, error)

Functions

func ConnectRabbitMQ

func ConnectRabbitMQ(username, password, host, vhost string) (*amqp.Connection, error)

ConnectRabbitMQ will spawn a Connection

Types

type Event

type Event struct {
	Name string
}

type RabbitClient

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

RabbitClient is used to keep track of the RabbitMQ connection

func NewRabbitMQClient

func NewRabbitMQClient(conn *amqp.Connection) (RabbitClient, error)

NewRabbitMQClient will connect and return a Rabbitclient with an open connection Accepts a amqp Connection to be reused, to avoid spawning one TCP connection per concurrent client

func (RabbitClient) Close

func (rc RabbitClient) Close() error

Close will close the channel

func (RabbitClient) Publish

func (rc RabbitClient) Publish(ctx context.Context, event Event) error

func (RabbitClient) QueueDeclare

func (rc RabbitClient) QueueDeclare() (amqp.Queue, error)

func (RabbitClient) Subscribe

func (rc RabbitClient) Subscribe(q string) (<-chan amqp.Delivery, error)