amqputil

package

v0.0.0-...-e42251a Latest Latest Go to latest Published: Feb 21, 2015 License: BSD-3-Clause Imports: 5 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

Repository

github.com/gwik/celery

Links

Open Source Insights

Documentation ¶

Overview ¶

Package amqputil provides utilities to work with http://github.com/streadway/amqp/ package.

Index ¶

type Retry
- func NewRetry(url string, config *amqp.Config, delay time.Duration) *Retry
- func (ar *Retry) Channel() <-chan *amqp.Channel
- func (ar *Retry) Close() error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Retry ¶

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

Retry connects to AMQP and retry on network failures.

func (*Retry) Channel ¶

func (ar *Retry) Channel() <-chan *amqp.Channel

Channel returns a chan of AMQP Channels. When the AMQP connection is ready it will be sent an AMQP Channel and will be closed. if the chan is closed before sending a channel it means an error occured and the receiver must not call the method again.

func (*Retry) Close ¶

func (ar *Retry) Close() error

Close closes the AMQP connections and stops the retry.

Source Files ¶

View all Source files

amqputil.go

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

Documentation ¶

Overview ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

Types ¶

type Retry ¶

func NewRetry ¶

func (*Retry) Channel ¶

func (*Retry) Close ¶

Source Files ¶