rabbitmq

Documentation

Index

• func CloseRabbitMQConnection()
• func ConnectToRabbitMQ()
• func GetRabbitMQChannel() *amqp.Channel
• func GetRabbitMQSubmissionsQueue() *amqp.Queue
• type SubmissionQueueMgr
  • func GetSubmissionQueueMgr() *SubmissionQueueMgr
  • func (manager *SubmissionQueueMgr) ListenForSubmissions()
• type SubmissionStatusUpdatesQueueMgr
  • func GetSubmissionStatusUpdatesQueueMgrInstance() *SubmissionStatusUpdatesQueueMgr
  • func (qMgr *SubmissionStatusUpdatesQueueMgr) QueueUpdate(updateDTO *dtos.SubmissionStatusUpdateDTO) (err error)

Functions

func CloseRabbitMQConnection

func CloseRabbitMQConnection()

func ConnectToRabbitMQ

func ConnectToRabbitMQ()

func GetRabbitMQChannel

func GetRabbitMQChannel() *amqp.Channel

func GetRabbitMQSubmissionsQueue

func GetRabbitMQSubmissionsQueue() *amqp.Queue

GetRabbitMQSubmissionsQueue returns a pointer to the submissions queue

Types

type SubmissionQueueMgr

type SubmissionQueueMgr struct {
	Queue          *amqp.Queue
	MessageChannel <-chan amqp.Delivery
	UseCases       *application.SubmissionsUseCases
}

func GetSubmissionQueueMgr

func GetSubmissionQueueMgr() *SubmissionQueueMgr

GetSubmissionQueueMgr returns a pointer to the singleton instance of SubmissionQueueMgr

func (*SubmissionQueueMgr) ListenForSubmissions

func (manager *SubmissionQueueMgr) ListenForSubmissions()

ListenForSubmissions starts listening for submissions

type SubmissionStatusUpdatesQueueMgr

type SubmissionStatusUpdatesQueueMgr struct {
	Queue *amqp.Queue
}

func GetSubmissionStatusUpdatesQueueMgrInstance

func GetSubmissionStatusUpdatesQueueMgrInstance() *SubmissionStatusUpdatesQueueMgr

GetSubmissionStatusUpdatesQueueMgrInstance returns a pointer to the submission status updates queue

func (*SubmissionStatusUpdatesQueueMgr) QueueUpdate

func (qMgr *SubmissionStatusUpdatesQueueMgr) QueueUpdate(updateDTO *dtos.SubmissionStatusUpdateDTO) (err error)

QueueUpdate queues a submission status update