rabbitmq

package

v1.4.2 Latest Latest Go to latest Published: Oct 20, 2020 License: Apache-2.0 Imports: 8 Imported by: 1

Details

View Source

const (
	DefaultWaitDuration = time.Millisecond * 50
)

This section is empty.

This section is empty.

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

func New(cfg *config.Resource) (*RabbitMQ, error)

New creates and validates the resource params for the connection initialized in Open()

func (c *RabbitMQ) Close() error

Close cleans up the underlying connection

func (c *RabbitMQ) Fetch(target string) ([][]byte, error)

Fetch attempts to retrieve a message from the passed target

func (c *RabbitMQ) Listen(target string) error

Listen creates a consumer on the passed target, creates the queue, and puts the messages into consumedMessage map for later access

func (c *RabbitMQ) Open() error

Open attempts a dial connection to the AMQP server

func (c *RabbitMQ) Publish(target string, payload []byte) error

Publish attempts to publish a message to the passed target

func (c *RabbitMQ) PublishFromFile(target string, fileName string) error

PublishFromFile attempts to publish a message read from a file to the passed target

func (c *RabbitMQ) Ready() error

Ready attempts to publish a message to a test queue, if no error is returned the server is deemed ready

func (c *RabbitMQ) Reset() error

Reset empties the consumedMessage map and cleans up the queues