publisher

type Message struct {
	ContentType string
	Body        []byte
	Opts        []PublishOption
}

type Middleware func(next RoundTripper) RoundTripper

type Option func(p *Publisher)

type PublishOption = func(*frame.Frame) error

type Publisher struct {
	Address     string
	Queue       string
	ConnOpts    []consumer.ConnOption
	Middlewares []Middleware
	// contains filtered or unexported fields
}

type RoundTripper interface {
	Publish(ctx context.Context, queue string, msg *Message) error
}

type RoundTripperFunc func(ctx context.Context, queue string, msg *Message) error