Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockRabbitMQClient ¶
func (*MockRabbitMQClient) Close ¶
func (m *MockRabbitMQClient) Close()
type RabbitMQClient ¶
type RabbitMQClient struct { Ctx context.Context Channel *amqp.Channel Queue string // contains filtered or unexported fields }
func NewRabbitMQClient ¶
func NewRabbitMQClient(ctx context.Context, connUrl string) (*RabbitMQClient, error)
Create new RabbitMQ amqp client, using amqp:// connection string
func (*RabbitMQClient) Close ¶
func (c *RabbitMQClient) Close()
func (*RabbitMQClient) Publish ¶
func (c *RabbitMQClient) Publish(id string, msg any, priority uint8) error
func (*RabbitMQClient) Reconnect ¶
func (c *RabbitMQClient) Reconnect() error
Reconnect reconnects the connection
Click to show internal directories.
Click to hide internal directories.