rabbitmq

Jun 14, 2026

Changes in this version

type RabbitMQConfig

+ Workers int

+ func (c *RabbitMQConfig) GetWorkers() int

Jun 14, 2026

Changes in this version

type RabbitMQConfig

+ MaxReconnectAttempts int

+ func (c *RabbitMQConfig) GetMaxReconnectAttempts() int

May 16, 2026

Changes in this version

type RabbitMQConfig

+ Producer config.ProducerConfig

+ Subscription string

+ Topic string

May 15, 2026

Changes in this version

+ type RabbitMQ struct

+ Channel *amqp.Channel

+ Config RabbitMQConfig

+ Connection *amqp.Connection

+ Receivers []port.PubSubReceiver

+ func NewRabbitMQ(ctx context.Context, cfg RabbitMQConfig) (*RabbitMQ, error)

+ func (r *RabbitMQ) Connect() error

+ func (r *RabbitMQ) Disconnect() error

+ func (r *RabbitMQ) Install(args ...any) error

+ func (r *RabbitMQ) Publish(ctx context.Context, message any, attributes map[string]string) (string, error)

+ func (r *RabbitMQ) RegisterReceiver(receiver port.PubSubReceiver)

+ func (r *RabbitMQ) StartReceiving(ctx context.Context)

+ func (r *RabbitMQ) Uninstall() error

+ type RabbitMQConfig struct

+ AutoDelete bool

+ Durable bool

+ ExchangeType string

+ Exclusive bool

+ PrefetchCount int

+ Uri string

+ func (c *RabbitMQConfig) SetDefaults() map[string]any

+ func (c *RabbitMQConfig) SetEnvBindings() map[string]string

+ type RabbitMQLoader struct

+ func (a *RabbitMQLoader) Name() string

+ func (a *RabbitMQLoader) SetName(name string)

+ func (l *RabbitMQLoader) Init(args ...any) (port.Library, error)

+ type RabbitMQMessage struct

+ Attributes map[string]string

+ Data []byte

+ ID string

+ PublishTime time.Time

+ func (m *RabbitMQMessage) GetAttributes() map[string]string

+ func (m *RabbitMQMessage) GetData() []byte

+ func (m *RabbitMQMessage) GetID() string

+ func (m *RabbitMQMessage) GetPublishTime() time.Time