rabbitmq

package
v0.0.0-...-788e3c4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 13, 2022 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// LocationDiscoveredExchange is the exchange that handles LocationDiscovered events
	LocationDiscoveredExchange = "LocationDiscovered"
	// LocationCreatedExchange is the exchange that handles LocationCreated events
	LocationCreatedExchange = "LocationCreated"
	// TicketDiscoveredExchange is the exchange that handles TicketDiscovered events
	TicketDiscoveredExchange = "TicketDiscovered"
)
View Source
const (
	// LocationDiscoveredQueue is the queue through which LocationDiscovered events travel
	LocationDiscoveredQueue = LocationDiscoveredExchange
	// LocationCreatedQueue is the queue through which LocationCreated events travel
	LocationCreatedQueue = LocationCreatedExchange
	// TicketDiscoveredQueue is the queue through which TicketDiscovered events travel
	TicketDiscoveredQueue = TicketDiscoveredExchange
)
View Source
const (
	// MediaPutEventKey is the routing key for when an image gets created
	MediaPutEventKey = "images.created"
)

Variables

This section is empty.

Functions

func NewConnection

func NewConnection(ctx context.Context, l cslog.Logger, host string) (*amqp.Connection, error)

NewConnection connects to RabbitMQ and initializes configuration in the broker. Please defer the closing of the returned connection

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL