sample

package
v0.0.0-...-7a3fe27 Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2024 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Exchanges = map[string]*internal.Exchange{
	"app.internal": {Name: "app.internal", Bindings: []*internal.Binding{
		{Id: uuid.New(), Queue: "events", RoutingKey: "#"},
	}},
	"app.external": {Name: "app.external", Bindings: []*internal.Binding{
		{Id: uuid.New(), Queue: "tmp", RoutingKey: "#"},
	}},
}
View Source
var Queues = map[string]*internal.Queue{
	"events": {
		Name:       "events",
		Durability: internal.Durability.DURABLE,
		Messages:   []*internal.Message{},
	},
	"tmp": {
		Name:       "tmp",
		Durability: internal.Durability.TRANSIENT,
		Messages: []*internal.Message{
			{Id: uuid.New(), Payload: "Message 1 (tmp)"},
			{Id: uuid.New(), Payload: "Message 2 (tmp)"},
			{Id: uuid.New(), Payload: "Message 3 (tmp)"},
			{Id: uuid.New(), Payload: "Message 4 (tmp)"},
			{Id: uuid.New(), Payload: "Message 5 (tmp)"},
		},
	},
	internal.DeadLetterQueueName: {
		Name:       internal.DeadLetterQueueName,
		Durability: internal.Durability.DURABLE,
		System:     true,
		Messages:   []*internal.Message{},
	},
}

Functions

This section is empty.

Types

This section is empty.

Jump to

Keyboard shortcuts

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