rabbitmq

Documentation

Index

• Variables
• func Open(uri string, exchange string, queues rabbitmq.Queues, mapper rabbitmq.Events, ...) (*rabbitmq.RabbitMQ, error)
• type Events
• type RabbitMQ

Variables

var (
	Close = rabbitmq.Close
)

var Queues = rabbitmq.Queues{
	user.CreatedSucceededKey: &rabbitmq.Recipient{
		Name: messages.NewRecipient(&messages.RecipientComponents{
			Service: "user",
			Entity:  "user",
			Action:  "send confirmation",
			Event:   "created",
			Status:  "succeeded",
		}),
		BindingKey: user.CreatedSucceededKey,
		Attributes: reflect.TypeOf(new(user.CreatedSucceededAttributes)),
	},
}

Functions

func Open

func Open(uri string, exchange string, queues rabbitmq.Queues, mapper rabbitmq.Events, logger loggers.Logger) (*rabbitmq.RabbitMQ, error)

Types

type Events

type Events = rabbitmq.Events

type RabbitMQ

type RabbitMQ = rabbitmq.RabbitMQ