queue

package

v0.0.0-...-3f9ec74 Latest Latest Go to latest Published: Jun 20, 2023 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const HEARTBEAT_DEFAULT = 10

This section is empty.

func CloseConnection() error

CloseConnection close RabbitMQ connection

func GetConnection() *amqp.Connection

GetConnectionReadOnly Obtém conexão de leitura com RabbitMQ

func GetQueueConfiguration() *rabbit.Config

func OpenConnection() error

OpenConnectionReadOnly Abre conexão de leitura com RabbitMQ

func WriteMessage(queuePublisher PublisherInterface) bool

WriteMessage Publica um messagem na fila

type Publisher struct {
	ExchangeName string
	QueueName    string
	RoutingKey   string
	Message      string
}

Publisher Implementação da interface publisher

func NewPublisher(message string) *Publisher

func (p *Publisher) GetExchangeName() string

GetExchangeName Retorna o nome da fila

func (p *Publisher) GetMessageToPublish() []byte

GetMessageToPublish Retorna a mensagem convertida para publicação na fila

func (p *Publisher) GetQueueName() string

GetQueueName Retorna o nome da fila com sufixo identificador

func (p *Publisher) GetRoutingKey() string

GetRoutingKey Retorna a RoutingKey para direcionamento da mensagem

type PublisherInterface interface {
	GetExchangeName() string
	GetQueueName() string
	GetRoutingKey() string
	GetMessageToPublish() []byte
}

PublisherInterface Interface do Publicador