rabbitmq

package
v0.0.0-...-cdd020a Latest Latest
Warning

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

Go to latest
Published: Feb 15, 2020 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Debug bool

Debug debug log flag

Functions

This section is empty.

Types

type Channel

type Channel struct {
	*amqp.Channel
	// contains filtered or unexported fields
}

Channel amqp.Channel wapper

func (*Channel) Close

func (ch *Channel) Close() error

Close ensure closed flag set

func (*Channel) Consume

func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

Consume warp amqp.Channel.Consume, the returned delivery will end only when channel closed by developer

func (*Channel) IsClosed

func (ch *Channel) IsClosed() bool

IsClosed indicate closed by developer

type Connection

type Connection struct {
	*amqp.Connection
}

Connection amqp.Connection wrapper

func Dial

func Dial(url string) (*Connection, error)

Dial wrap amqp.Dial, dial and get a reconnect connection

func (*Connection) Channel

func (c *Connection) Channel(exchange *Exchange, queue *Queue, bind *QueueBind) (*Channel, error)

Channel wrap amqp.Connection.Channel, get a auto reconnect channel

type Exchange

type Exchange struct {
	ExchangeName string
	Kind         string
	Durable      bool
	AutoDelete   bool
	Internal     bool
	NoWait       bool
	Args         amqp.Table
}

type Queue

type Queue struct {
	QueueName  string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	Args       amqp.Table
}

type QueueBind

type QueueBind struct {
	Key  string
	Args amqp.Table
}

Jump to

Keyboard shortcuts

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