rabbitmq

type Config struct {
	AMQPUrl      string `json:"amqp_url"`
	Host         string `json:"host"`
	Port         string `json:"port"`
	Vhost        string `json:"vhost"`
	Username     string `json:"username"`
	Password     string `json:"password"`
	ExchangeName string `json:"exchange_name"`
	ExchangeType string `json:"exchange_type"`
	QueueName    string `json:"queue_name"`
}

type Consumer struct {
	*RabbitMQ
	// contains filtered or unexported fields
}

type IConsumer interface {
	Consume()
}

type IPublisher interface {
	Publish(payload []byte, routingKey string, reliable bool) (err error)
}

type IRabbitMQ interface {
	NewConnection() (*amqp.Connection, error)
	CloseConnection() error
	NewChannel() (*amqp.Channel, error)
	EnsureConnection() (err error)
	CloseChannel() error
	DeclareExchange() error
	DeclareQueue() error
	BindQueue(exchange, routingKey string) error
	Setup()
	ChanelIsClosed() bool
}

type Option interface {
	// contains filtered or unexported methods
}

type Publisher struct {
	*RabbitMQ
}

type RabbitMQ struct {
	// contains filtered or unexported fields
}