rabbitmq

type Channel interface {
	FanoutExchangeDeclare(exchange string) error
	QueueDeclareAndBind(exchange, queue string) error
	Publish(queue string, message Message) error
	Consume(ctx context.Context, queue string) (<-chan Message, error)
	Close() error
}

type Connection interface {
	GetChannel() (Channel, error)
	Close() error
}

type Message = []byte

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

type PubSubManagerSetter interface {
	SetPublishHandler(handler PublishHandler) error
}

type PublishHandler = func(Channel, interface{})

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