rabbitmq

package

v0.1.21 Latest Latest Go to latest Published: Dec 19, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

RabbitMQ represents RabbitMQ implementation

func NewRabbitMQ(conn *amqp.Connection) *RabbitMQ

NewRabbitMQ creates new RabbitMQ connection

func NewRabbitMQWithConfig(conn *amqp.Connection, messaging *config.Messaging) *RabbitMQ

NewRabbitMQWithConfig creates new RabbitMQ with messaging config

func (s *RabbitMQ) Close() error

Close closes the RabbitMQ service

func (s *RabbitMQ) ConsumeMessages(queue string, handler func([]byte) error) error

ConsumeMessages consumes messages from RabbitMQ

func (s *RabbitMQ) IsConnected() bool

IsConnected checks if the RabbitMQ connection is valid

func (s *RabbitMQ) PublishMessage(exchange, routingKey string, body []byte) error

PublishMessage publishes message to RabbitMQ