rabbitmq

type AMQPChannel interface {
	ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
	ExchangeBind(destination, key, source string, noWait bool, args amqp.Table) error
	QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
	QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error
	Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
	Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
}

type AMQPConnection interface {
	Channel() (*amqp.Channel, error)
}

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

type ConsumerHandler = func(ctx context.Context, msg any, metadata any) error

type Dispatcher interface {
	Register(queue string, msg any, handler ConsumerHandler) error
	ConsumeBlocking(ch chan os.Signal)
}

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

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

type ExchangeKind string

type Publisher interface {
	SimplePublish(ctx context.Context, target string, msg any) error
	Publish(ctx context.Context, exchange, key string, msg any) error
}

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

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

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

type Topology interface {
	Channel(c AMQPChannel) Topology
	Queue(q *QueueDefinition) Topology
	Queues(queues []*QueueDefinition) Topology
	Exchange(e *ExchangeDefinition) Topology
	Exchanges(e []*ExchangeDefinition) Topology
	ExchangeBinding(b *ExchangeBindingDefinition) Topology
	QueueBinding(b *QueueBindingDefinition) Topology
	GetQueuesDefinition() map[string]*QueueDefinition
	GetQueueDefinition(queueName string) (*QueueDefinition, error)
	Apply() error
}