Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRabbitMQConn ¶
func NewRabbitMQConn(ctx context.Context, cfg *RabbitMQConfig) (*amqp.Connection, error)
Types ¶
type Consumer ¶
type Consumer[T any] struct { // contains filtered or unexported fields }
func (Consumer[T]) ConsumeMessage ¶
func (Consumer[T]) IsConsumed ¶
type IConsumer ¶
type IPublisher ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
func NewPublisher ¶
func NewPublisher(ctx context.Context, cfg *RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, jaegerTracer trace.Tracer) *Publisher
func (*Publisher) IsPublished ¶
func (*Publisher) PublisherMessage ¶
Click to show internal directories.
Click to hide internal directories.