amqp

package

v0.0.0-...-87b6a28 Latest Latest Go to latest Published: Apr 19, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ConnectionIdentifier string

	InstanceId string

	AmqpHost string
	AmqpUser string
	AmqpPass string
	AmqpPort int
)

func Consume(deliveryTag string, handlerFunc HandlerFunc, count int) (*sync.WaitGroup, *sync.WaitGroup)

func ConsumeForever(deliveryTag string, handlerFunc HandlerFunc) (*sync.WaitGroup, *sync.WaitGroup)

func ConsumeSingle(deliveryTag string, handlerFunc HandlerFunc) (*sync.WaitGroup, *sync.WaitGroup)

func Decode(in []byte, typ interface{}) interface{}

func Encode(in interface{}) []byte

func GetChannel(name string) (*amqp.Channel, error)

func Publish(routingKey string, msg amqp.Publishing) error

func PublishPb(msg interface{})

func PublishPbWithChannel(c *amqp.Channel, msg interface{})

func PublishWithChannel(c *amqp.Channel, routingKey string, msg amqp.Publishing) error

func StartServerListener()

type Delivery struct {
	Message amqp.Delivery
}

A dumb Delivery wrapper, so dependencies on this lib don't have to depened on the streadway lib

type HandlerFunc func(d Delivery)