queue

package
v0.0.0-...-7b951aa Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RabbitMQ 

type RabbitMQ struct {
	User              string
	Password          string
	Host              string
	Port              string
	Vhost             string
	ConsumerQueueName string
	ConsumerName      string
	AutoAck           bool
	Args              amqp.Table
	Channel           *amqp.Channel
}

func NewRabbitMQ 

func NewRabbitMQ() *RabbitMQ

func (*RabbitMQ) Connect 

func (r *RabbitMQ) Connect() *amqp.Channel

func (*RabbitMQ) Consume 

func (r *RabbitMQ) Consume(messageChannel chan amqp.Delivery)

func (*RabbitMQ) Notify 

func (r *RabbitMQ) Notify(message string, contentType string, exchange string, routingKey string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.