rabbitMQ

package
v0.4.5 Latest Latest
Warning

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

Go to latest
Published: Jan 12, 2021 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Connection

type Connection struct {
	URL      string
	Exchange string
	Queues   []string
	// contains filtered or unexported fields
}

func (*Connection) BindQueue

func (c *Connection) BindQueue() error

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) Connect

func (c *Connection) Connect() error

func (*Connection) Consume

func (c *Connection) Consume() (map[string]<-chan amqp.Delivery, error)

func (*Connection) Publish

func (c *Connection) Publish(m Message) error

func (*Connection) Reconnect

func (c *Connection) Reconnect() error

type Message

type Message struct {
	Queue         string
	ReplyTo       string
	ContentType   string
	CorrelationID string
	Priority      uint8
	Body          []byte
}

Jump to

Keyboard shortcuts

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