Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type RabbitMQConnection ¶
type RabbitMQConnection interface { GetChannel() *amqp.Channel RegisterHandler(RabbitMQListnerInterface) error SendMessage(ctx context.Context, message any, routing string, extraheaders map[string]interface{}) error clients.CommonClient }
func NewRabbitMQConnection ¶
func NewRabbitMQConnection(cp RabbitMQCredentialProvider, host string, port string, broadcastName string) RabbitMQConnection
Click to show internal directories.
Click to hide internal directories.