rabbitmq

type Acknowledger interface {
	AcknowledgeSingleMessage(uint64) error
	AcknowledgeMultipleMessages(uint64) error
}

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

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

type Channel interface {
	Consumer
	Publisher

	Close() error
}

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

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

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

type Connector interface {
	Connect(url.URL) (Connection, error)
}

type Consumer interface {
	Acknowledger

	ConfigureChannelBuffer(int) error
	DeclareExchange(string, string) error
	DeclareQueue(string) error
	DeclareTransientQueue() (string, error)
	BindExchangeToQueue(string, string) error

	Consume(string, string) (<-chan amqp.Delivery, error)
	ExclusiveConsume(string, string) (<-chan amqp.Delivery, error)
	ConsumeWithoutAcknowledgement(string, string) (<-chan amqp.Delivery, error)
	ExclusiveConsumeWithoutAcknowledgement(string, string) (<-chan amqp.Delivery, error)

	CancelConsumer(string) error
}

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

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

type Publisher interface {
	ConfigureChannelAsTransactional() error

	PublishMessage(string, string, amqp.Publishing) error

	CommitTransaction() error
	RollbackTransaction() error
}

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

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