amqptest

package

v0.0.0-...-d7ad24d Latest Latest Go to latest Published: Dec 12, 2019 License: BSD-2-Clause Imports: 6 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

This section is empty.

This section is empty.

func Dial(amqpuri string) (wabbit.Conn, error)

Dial mock the connection dialing to rabbitmq and returns the established connection or error if something goes wrong

type Conn struct {
	ConnID string
	// contains filtered or unexported fields
}

Conn is the fake AMQP connection

func (conn *Conn) AutoRedial(outChan chan wabbit.Error, done chan bool)

AutoRedial mock the reconnection faking a delay of 1 second

func (conn *Conn) Channel() (wabbit.Channel, error)

Channel creates a new fake channel

func (conn *Conn) Close() error

Close the fake connection

func (conn *Conn) NotifyClose(c chan wabbit.Error) chan wabbit.Error

NotifyClose publishs notifications about server or client errors in the given channel

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

func NewPublisher(conn wabbit.Conn, channel wabbit.Channel) (*Publisher, error)

func (pb *Publisher) Publish(exc string, route string, message []byte, opt wabbit.Option) error

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

func NewQueue(name string) *Queue

func (q *Queue) Consumers() int

func (q *Queue) Messages() int

func (q *Queue) Name() string

Path	Synopsis
server