Documentation ¶
Index ¶
- func CleanQueue(queueName string, channel *amqp.Channel) error
- func ConnectToQueue(mq lanternmq.MessageQueue, ch lanternmq.ChannelID, qName string) (lanternmq.MessageQueue, lanternmq.ChannelID, error)
- func ConnectToServerAndQueue(qUser, qPassword, qHost, qPort, qName string) (lanternmq.MessageQueue, lanternmq.ChannelID, error)
- func QueueCount(queueName string, channel *amqp.Channel) (int, error)
- func SendToQueue(ctx context.Context, message string, mq *lanternmq.MessageQueue, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CleanQueue ¶
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 ¶
QueueCount counts how many messages are currently in the queue
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.