rabbitmq

Documentation

Index

• Variables
• func Exchange(name string) *messages.Router
• type Consumers
• type Queues
• type RabbitMQ
  • func Open(uri string, logger loggers.Logger, exchange *messages.Router, ...) (*RabbitMQ, error)

Variables

var (
	BindingEventCreatedSucceeded = "#.event.#.created.succeeded"
)

var (
	Close = rabbitmq.Close
)

Functions

func Exchange

func Exchange(name string) *messages.Router

Types

type Consumers

type Consumers = []messages.Consumer

type Queues

type Queues = []*messages.Queue

type RabbitMQ

type RabbitMQ = rabbitmq.RabbitMQ

func Open

func Open(uri string, logger loggers.Logger, exchange *messages.Router, queues []*messages.Queue, consumers []messages.Consumer) (*RabbitMQ, error)