diacon

Documentation

Index

• func Connect(cfg RabbitMQConfiguration) (*amqp.Connection, error)
• type RabbitMQConfiguration

Functions

func Connect

func Connect(cfg RabbitMQConfiguration) (*amqp.Connection, error)

Get a connection for given configuration(will be passed to pubs and subs)

Types

type RabbitMQConfiguration

type RabbitMQConfiguration struct {
	URL  string //Without the port
	Port string //Port(string) w/o :
}

A configuration for connecting to RabbitMQ