Versions in this module Expand all Collapse all v0 v0.0.1 Jun 25, 2025 Changes in this version + type Options struct + Exchange string + ExchangeType string + PrefetchCount int + URI string + func DefaultOptions() Options + type RMQJob struct + type RabbitMQBroker struct + func NewBroker(options Options, serializer core.Serializer) *RabbitMQBroker + func (r *RabbitMQBroker) Ack(ctx context.Context, j job.Job) error + func (r *RabbitMQBroker) Capabilities() core.BrokerCapabilities + func (r *RabbitMQBroker) Close() error + func (r *RabbitMQBroker) Connect(ctx context.Context) error + func (r *RabbitMQBroker) CreateQueue(ctx context.Context, name string, options core.QueueOptions) error + func (r *RabbitMQBroker) DeleteQueue(ctx context.Context, name string) error + func (r *RabbitMQBroker) Dequeue(ctx context.Context, queue string) (job.Job, error) + func (r *RabbitMQBroker) Enqueue(ctx context.Context, j job.Job) error + func (r *RabbitMQBroker) Health() error + func (r *RabbitMQBroker) Nack(ctx context.Context, j job.Job, requeue bool) error + func (r *RabbitMQBroker) QueueExists(ctx context.Context, name string) (bool, error) + func (r *RabbitMQBroker) QueueLength(ctx context.Context, name string) (int64, error) + func (r *RabbitMQBroker) SetLogger(logger seelog.LoggerInterface) + func (r *RabbitMQBroker) Type() string
Go to main page