transport

type AMQPTransport struct {
	context.Context
	URL          string
	ExchangeName string
	ExchangeKind string
	// contains filtered or unexported fields
}

type Driver interface {
	Init(context.Context) error
	Name() string
	Tomb() *tomb.Tomb
	Setup() error
	Close() error
	Consume(string) (<-chan *message.Request, error)
	Reply(*message.Request, message.Response) error
}