messaging

Documentation

Index

• Constants
• func NewRabbitPublisher(file string, pool *database.Pool, mtx *sync.Mutex, dispatchers int) *migration.MessageService
• type Channels
  • func NewChannels() *Channels
• type Mailer
  • func NewMailer() *Mailer
  • func (m *Mailer) GetBody() string
  • func (m *Mailer) GetMimeHeaders() string
  • func (m *Mailer) GetSubject() string
  • func (m *Mailer) GetTo() string
  • func (m *Mailer) Send() error
  • func (m *Mailer) SetBody(body string)
  • func (m *Mailer) SetConfig(config map[string]string)
  • func (m *Mailer) SetMimeHeaders(mimeHeaders string)
  • func (m *Mailer) SetSubject(subject string)
  • func (m *Mailer) SetTo(to string)
• type Rabbit
  • func NewRabbit(file string) *Rabbit
  • func (r *Rabbit) Consume(queue string, callback func(amqp.Delivery)) error
  • func (r *Rabbit) ConsumeResilient(queue string, callback func(amqp.Delivery)) error
  • func (r *Rabbit) ConsumeWithContext(ctx context.Context, queue string, callback func(amqp.Delivery)) error
  • func (r *Rabbit) DeclareExchange(exchange string) error
  • func (r *Rabbit) DeclareQueue(queue, exchange, routingKey string) error
  • func (r *Rabbit) Disconnect() error
  • func (r *Rabbit) IsConnected() bool
  • func (r *Rabbit) Publish(exchange, routingKey string, body []byte) error
  • func (r *Rabbit) PublishFromCache(messageService *migration.MessageService, mtx *sync.Mutex) error
• type RabbitConfig
  • func (r *RabbitConfig) LoadRabbitConfig(file string) error

Constants

const (
	MESSAGING_TIMEOUT = 30
	MAX_RETRIES       = 3
)

Functions

func NewRabbitPublisher

func NewRabbitPublisher(file string, pool *database.Pool, mtx *sync.Mutex, dispatchers int) *migration.MessageService

NewRabbitPublisher is a function that creates a new RabbitMQ publisher and publishes all messages from the database. It is used to publish messages that were not published due to a RabbitMQ connection failure. The messages are published unordered The table used to store the messages is: create table if not exists RabbitCache(RabbitCacheID string primary key, DE_Exchange string, DE_RoutingKey string, JS_Data text, SN_Durable integer, TS_Operacao string, ID_Status integer default 0) The table is created in memory and is not persisted. To send a message, you have to call the function Send of the message service that uses the same database connection. the function needs the following parameters: - exchange: the exchange name - routingKey: the routing key - data: the message data - durable: if the message is durable CAUTION: if you use more than one dispatcher, the messages can be sent more than once. You have to take care of this. The function returns a message service that can be used to send messages.

Types

type Channels

type Channels struct {
	// Channel for sending messages to the messaging adapter
	// Each message must have the following structure:
	// {
	// 	"EM_Destinatario": "email address",
	// 	"DE_Body": "message body",
	//  "DE_Assunto": "message subject
	// }
	Email chan map[string]interface{}
	// Channel for sending messages to the messaging adapter
	// Each message must have the following structure:
	// {
	// 	"DE_Telefone": "phone number",
	// 	"DE_Mensagem": "message body",
	// }
	SMS chan map[string]string
	// Channel for sending messages to the messaging adapter
	// Each message must have the following structure:
	// {
	// 	"DE_Telefone": "phone number",
	// 	"DE_Mensagem": "message body",
	// }
	Whatsapp chan map[string]interface{}
	// Channel for sending messages to the messaging adapter
	// Each message must have the following structure:
	// {
	// 	"exchange": "exchange name",
	// 	"routingKey": "routing key",
	// 	"body": "message body",
	// 	"durable": "if the message is durable",
	// }
	Messaging chan map[string]interface{}
	// Channel for sending shutdown signal to the web server
	Shutdown chan bool
}

func NewChannels

func NewChannels() *Channels

type Mailer

type Mailer struct {
	// contains filtered or unexported fields
}

func NewMailer

func NewMailer() *Mailer

func (*Mailer) GetBody

func (m *Mailer) GetBody() string

func (*Mailer) GetMimeHeaders

func (m *Mailer) GetMimeHeaders() string

func (*Mailer) GetSubject

func (m *Mailer) GetSubject() string

func (*Mailer) GetTo

func (m *Mailer) GetTo() string

func (*Mailer) Send

func (m *Mailer) Send() error

func (*Mailer) SetBody

func (m *Mailer) SetBody(body string)

func (*Mailer) SetConfig

func (m *Mailer) SetConfig(config map[string]string)

func (*Mailer) SetMimeHeaders

func (m *Mailer) SetMimeHeaders(mimeHeaders string)

func (*Mailer) SetSubject

func (m *Mailer) SetSubject(subject string)

func (*Mailer) SetTo

func (m *Mailer) SetTo(to string)

type Rabbit

type Rabbit struct {
	// contains filtered or unexported fields
}

func NewRabbit

func NewRabbit(file string) *Rabbit

func (*Rabbit) Consume

func (r *Rabbit) Consume(queue string, callback func(amqp.Delivery)) error

func (*Rabbit) ConsumeResilient

func (r *Rabbit) ConsumeResilient(queue string, callback func(amqp.Delivery)) error

func (*Rabbit) ConsumeWithContext

func (r *Rabbit) ConsumeWithContext(ctx context.Context, queue string, callback func(amqp.Delivery)) error

func (*Rabbit) DeclareExchange

func (r *Rabbit) DeclareExchange(exchange string) error

func (*Rabbit) DeclareQueue

func (r *Rabbit) DeclareQueue(queue, exchange, routingKey string) error

func (*Rabbit) Disconnect

func (r *Rabbit) Disconnect() error

func (*Rabbit) IsConnected

func (r *Rabbit) IsConnected() bool

func (*Rabbit) Publish

func (r *Rabbit) Publish(exchange, routingKey string, body []byte) error

func (*Rabbit) PublishFromCache

func (r *Rabbit) PublishFromCache(messageService *migration.MessageService, mtx *sync.Mutex) error

type RabbitConfig

type RabbitConfig struct {
	DSN string `json:"dsn"`
	// contains filtered or unexported fields
}

func (*RabbitConfig) LoadRabbitConfig

func (r *RabbitConfig) LoadRabbitConfig(file string) error