Versions in this module Expand all Collapse all v1 v1.0.1001 Dec 3, 2023 v1.0.1000 Aug 22, 2023 Changes in this version + func NewRabbitMQ(tag string, tracing tracing.Tracing, lo logger.Logger, ...) database.RabbitMQ + type Consumer struct + func NewConsumer(tracing tracing.Tracing, lg logger.Logger, dialer *Dialer, ...) *Consumer + func (c *Consumer) Init() + func (c *Consumer) OnSession(queue string, sub Session, messages chan<- Message) + func (c *Consumer) Subscribe(sessions chan chan Session, messages chan<- Message) + func (c *Consumer) Write() chan<- Message + type Dialer struct + Session chan chan Session + func NewDialer(id string, lg logger.Logger) *Dialer + func (c *Dialer) Dial(cx context.Context, config interfaces.RabbitMQProviderConfig, onError OnError, ...) + func (c *Dialer) IsConnected() bool + type Message struct + Body []byte + Headers map[string]interface{} + type MsgSend struct + Data []byte + Headers map[string]interface{} + ID string + Name string + type OnConnected func() + type OnError func(error) + type PendingQue struct + type Producer struct + func NewProducer(lg logger.Logger, dialer *Dialer, config database.RabbitMQProviderConfig, ...) *Producer + func (c *Producer) Init() + func (c *Producer) Publish(sessions chan chan Session) + func (c *Producer) SendingData(id string, key string, body interface{}, headers map[string]interface{}, ...) + type RabbitMQ struct + func (c *RabbitMQ) Consumer(options database.RabbitMQOptions, callback database.ConsumerCallback) + func (c *RabbitMQ) Producer(options database.RabbitMQOptions) + func (c *RabbitMQ) Push(ctx context.Context, id, exchange, key string, body interface{}, ...) error + type Session struct + func (s *Session) Close() error + type Stores struct + func NewStore() *Stores + func (c *Stores) Delete(id string) + func (c *Stores) Get(id string) (cb database.ConsumerCallback, ok bool) + func (c *Stores) LoadClient(id string) (client *RabbitMQ, ok bool) + func (c *Stores) LoadClientByTag(ta string) (client *RabbitMQ, ok bool) + func (c *Stores) Put(id string, cb database.ConsumerCallback) + func (c *Stores) StoreClient(client *RabbitMQ)