Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rmq

package module

Go to main page

Versions in this module

v1

v1.1.1

Sep 14, 2024

Changes in this version

+ const QueueTypeClassic

+ const QueueTypeQuorum

+ const QueueTypeStream

type Client

+ QueueAutoDelete bool

+ QueueDurable bool

+ QueueType string

+ func (c *Client) SetQueueDurable(durable bool)

+ func (c *Client) SetQueueType(qType string)

+ func (c *Client) SettQueuAutoDelete(auto bool)

v1.1.0

Oct 13, 2023

v1.0.3

Jul 26, 2023

v1.0.2

Jun 25, 2021

Changes in this version

+ func SetUserDebug(f TraceFunc)

type TraceFunc

+ var UserTrace TraceFunc = nil

v1.0.1

Apr 22, 2021

Changes in this version

+ const ExchangeDirect

+ const ExchangeFanout

+ const ExchangeHeaders

+ const ExchangeTopic

+ const LevelAlert

+ const LevelCritical

+ const LevelDebug

+ const LevelEmergency

+ const LevelError

+ const LevelInformational

+ const LevelNotice

+ const LevelWarning

+ const Persistent

+ const Transient

+ func AddDebugFunc(f TraceFunc)

+ func Debug(enable bool)

+ func Publish(messages chan Message, c *Client)

+ func PublishWithRoutingKey(messages chan MessageWithRoutingKey, c *Client)

+ func SetLogger(l ...interface{})

+ func Subscribe(handle CallBack, c *Client)

+ func TraceError(format string, v ...interface{})

+ func TraceInfo(format string, v ...interface{})

+ type CallBack func(msg []byte)

+ type Client struct

+ DeliveryMode uint8

+ Exchange string

+ ExchangeEnable bool

+ ExchangeType string

+ ExpirationTime int32

+ MsgExpirationEnable bool

+ PublishStatus bool

+ Qos int

+ QueueBindEnable bool

+ QueueName string

+ RoutingKey string

+ URL string

+ func NewClient() *Client

+ func (c *Client) GetPublishStatus() bool

+ func (c *Client) Identity() string

+ func (c *Client) Info()

+ func (c *Client) SetDeliveryMode(dMode uint8)

+ func (c *Client) SetExchange(ex, exType string)

+ func (c *Client) SetExchangeEnable(enable bool)

+ func (c *Client) SetExpirationTime(time int32)

+ func (c *Client) SetMsgExpirationEnable(enable bool)

+ func (c *Client) SetPublishStatus(status bool)

+ func (c *Client) SetQos(qos int)

+ func (c *Client) SetQueueBindEnable(enable bool)

+ func (c *Client) SetQueueName(q string)

+ func (c *Client) SetRoutingKey(rkey string)

+ func (c *Client) SetURL(url, vhost, username, password string)

+ type Message []byte

+ type MessageWithRoutingKey struct

+ Message []byte

+ RoutingKey string

+ type Session struct

+ func (s Session) Close() error

+ type TraceFunc func(format string, level int, v ...interface{})

+ var DoFunc TraceFunc = nil