consumers

package
v0.0.0-...-ab6c89e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 17, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BaseConsumer

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

func (*BaseConsumer) BindQueue

func (bc *BaseConsumer) BindQueue(queueName, routingKey, exchangeName string) error

func (*BaseConsumer) DeclareExchange

func (bc *BaseConsumer) DeclareExchange(exchangeName, exchangeType string) error

func (*BaseConsumer) DeclareQueue

func (bc *BaseConsumer) DeclareQueue(queueName string) (amqp.Queue, error)

type IConsumer

type IConsumer[T any] interface {
	ConsumeMessage(msg interface{}, dependencies T) error
	IsConsumed(msg interface{}) bool
}

func NewOrderCancelledConsumer

func NewOrderCancelledConsumer[T any](ctx context.Context, cfg *queue.RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, handler func(queue string, msg amqp.Delivery, dependencies T) error) IConsumer[T]

func NewOrderConfirmedBufferConsumer

func NewOrderConfirmedBufferConsumer[T any](ctx context.Context, cfg *queue.RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, handler func(queue string, msg amqp.Delivery, dependencies T) error) IConsumer[T]

func NewOrderConfirmedConsumer

func NewOrderConfirmedConsumer[T any](ctx context.Context, cfg *queue.RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, handler func(queue string, msg amqp.Delivery, dependencies T) error) IConsumer[T]

type OrderCancelledConsumer

type OrderCancelledConsumer[T any] struct {
	*BaseConsumer
	// contains filtered or unexported fields
}

func (*OrderCancelledConsumer[T]) ConsumeMessage

func (c *OrderCancelledConsumer[T]) ConsumeMessage(msg interface{}, dependencies T) error

func (*OrderCancelledConsumer[T]) IsConsumed

func (c *OrderCancelledConsumer[T]) IsConsumed(msg interface{}) bool

type OrderConfirmedBufferConsumer

type OrderConfirmedBufferConsumer[T any] struct {
	*BaseConsumer
	// contains filtered or unexported fields
}

func (*OrderConfirmedBufferConsumer[T]) ConsumeMessage

func (c *OrderConfirmedBufferConsumer[T]) ConsumeMessage(msg interface{}, dependencies T) error

func (*OrderConfirmedBufferConsumer[T]) IsConsumed

func (c *OrderConfirmedBufferConsumer[T]) IsConsumed(msg interface{}) bool

type OrderConfirmedConsumer

type OrderConfirmedConsumer[T any] struct {
	*BaseConsumer
	// contains filtered or unexported fields
}

func (*OrderConfirmedConsumer[T]) ConsumeMessage

func (c *OrderConfirmedConsumer[T]) ConsumeMessage(msg interface{}, dependencies T) error

func (*OrderConfirmedConsumer[T]) IsConsumed

func (c *OrderConfirmedConsumer[T]) IsConsumed(msg interface{}) bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL