conn

Documentation

Index

• func Connect(args ConnArguments) (*amqp.Conn, *amqp.Session, error)
• type ConnArguments
• type ReceiveArguments
• type SendArguments

Functions

func Connect

func Connect(args ConnArguments) (*amqp.Conn, *amqp.Session, error)

Types

type ConnArguments

type ConnArguments struct {
	Server   string
	User     string
	Password string
}

type ReceiveArguments

type ReceiveArguments struct {
	Acknowledge               bool
	Durable                   bool
	Multicast                 bool
	Number                    int
	Queue                     string
	Timeout                   float32
	Wait                      bool
	WithHeaderAndProperties   bool
	WithApplicationProperties bool
}

type SendArguments

type SendArguments struct {
	Address       string
	ContentType   string
	CorrelationID string
	Durable       bool
	Message       []byte
	MessageID     string
	Multicast     bool
	Priority      uint8
	Properties    map[string]any
	ReplyTo       string
	Subject       string
	To            string
}