Documentation
¶
Index ¶
- type BaseConsumer
- type IConsumer
- func NewOrderCancelledConsumer[T any](ctx context.Context, cfg *queue.RabbitMQConfig, conn *amqp.Connection, ...) IConsumer[T]
- func NewOrderConfirmedBufferConsumer[T any](ctx context.Context, cfg *queue.RabbitMQConfig, conn *amqp.Connection, ...) IConsumer[T]
- func NewOrderConfirmedConsumer[T any](ctx context.Context, cfg *queue.RabbitMQConfig, conn *amqp.Connection, ...) IConsumer[T]
- type OrderCancelledConsumer
- type OrderConfirmedBufferConsumer
- type OrderConfirmedConsumer
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 }
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
Click to show internal directories.
Click to hide internal directories.