messaging

type Connection interface {
	Sender(address string) (Sender, error)
	Receiver(address string, credit uint32) (Receiver, error)
	Close()
}

type ConnectionFactory interface {
	Connect() (Connection, error)
	Url() string
}

type Receiver interface {
	Receive() (*amqp.Message, error)
	Accept(*amqp.Message) error
	Close() error
}

type Sender interface {
	Send(msg *amqp.Message) error
	Close() error
}