client

package
v0.3.19 Latest Latest
Warning

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

 Go to latest Published: Dec 28, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ExchangeTyeDirect   = "direct"
	ExchangeTypeFanout  = "fanout"
	ExchangeTypeTopic   = "topic"
	ExchangeTypeHeaders = "headers"
	DefaultExchangeType = ExchangeTypeTopic
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Conn 

type Conn struct {
	Config *rabbitmq.Config
	*amqp.Connection
}

func NewConn 

func NewConn(addr, user, pass, vhost string) (*Conn, error)

NewConn returns a new *Conn

func NewConnWithConfig 

func NewConnWithConfig(config *rabbitmq.Config) (*Conn, error)

NewConnWithConfig returns a new *Conn with given config

func NewConnWithDefault 

func NewConnWithDefault(addr, user, pass string) (*Conn, error)

NewConnWithDefault returns a new *Conn with default values

func (*Conn) Close 

func (c *Conn) Close() error

Close closes the connection

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.