rabbitmqclient

Documentation

Index

• func Ping() bool
• type RabbitMQConnection
  • func NewRabbitMQConnection(cp RabbitMQCredentialProvider, host string, port string, broadcastName string) RabbitMQConnection
• type RabbitMQCredentialProvider
• type RabbitMQListnerInterface

Functions

func Ping

func Ping() bool

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

type RabbitMQCredentialProvider

type RabbitMQCredentialProvider interface {
	GetCredentials() (string, string)
}

type RabbitMQListnerInterface

type RabbitMQListnerInterface interface {
	Listen(chan *amqp.Error)
}