rmq

package

v0.0.0-...-aac5273 Latest Latest Go to latest Published: Sep 29, 2017 License: BSD-2-Clause Imports: 4 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

View Source

const (
	// declare flags
	Durable   = uint(0x1)
	Exclusive = uint(0x2)

	// publish flags
	Mandatory = uint(0x1)
	Immediate = uint(0x2)
)

This section is empty.

func BasicConsume(c *Channel, queue string, ctag string, callback ConsumerCallback) error

func BasicPublish(c *Channel, exchange string, rk string, body []byte, headers map[string]interface{}, flags uint) error

func ExchangeDeclare(c *Channel, exchange, typ string, flags uint) error

func QueueBind(c *Channel, name, key, exchange string, args map[string]interface{}) error

func QueueDeclare(c *Channel, queue string, flags uint) error

type Channel = amqp.Channel

type Consumer struct {
	// contains filtered or unexported fields
}

func (c *Consumer) Tag() string

type ConsumerCallback func(msg *Message)

type Exchange struct {
	Headers string
	Topic   string
}

type Message struct {
	Body    []byte
	Headers map[string]interface{}
	// contains filtered or unexported fields
}

func (m *Message) Ack(success bool) error

func (m *Message) AckMultiple(success bool) error

func (m *Message) Reject(requeue bool) error

type RMQ struct {
	// contains filtered or unexported fields
}

func Connect(host string) (*RMQ, error)

func ConnectAndAnnounce(sett *Settings) (*RMQ, error)

func (r *RMQ) Channel(name string, prefetchCount int) (*Channel, error)

type Return = amqp.Return

type Service struct {
	Queue      string
	RoutingKey string
}

type Settings struct {
	Amqp     string
	Exchange Exchange
	Services map[string]Service
}