accessqueue

package
v0.0.0-...-3a37e37 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CleanQueue 

func CleanQueue(queueName string, channel *amqp.Channel) error

CleanQueue purges the messages in the given channel and then counts to make sure no messages are left

func ConnectToQueue 

func ConnectToQueue(mq lanternmq.MessageQueue, ch lanternmq.ChannelID, qName string) (lanternmq.MessageQueue, lanternmq.ChannelID, error)

ConnectToQueue uses the given connection to connect to the queue with the given queue name

func ConnectToServerAndQueue 

func ConnectToServerAndQueue(qUser, qPassword, qHost, qPort, qName string) (lanternmq.MessageQueue, lanternmq.ChannelID, error)

ConnectToServerAndQueue creates a connection to an exchange at the given location with the given credentials. then connects to the queue with the given queue name

func QueueCount 

func QueueCount(queueName string, channel *amqp.Channel) (int, error)

QueueCount counts how many messages are currently in the queue

func SendToQueue 

func SendToQueue(
	ctx context.Context,
	message string,
	mq *lanternmq.MessageQueue,
	ch *lanternmq.ChannelID,
	queueName string) error

SendToQueue publishes a message to the given queue

Types

This section is empty.

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.