queue

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IQueue

type IQueue interface {
	Exchange() string
	Name() string
	Bind() (*amqp.Channel, error)
	Publish(msgBytes []byte) error
}

func NewQueue

func NewQueue(connection connection.IConnection, exchange string, name string) IQueue

Jump to

Keyboard shortcuts

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