rmqimpl

type Bind struct {
	Key      string
	Exchange string
	Nowait   bool
}

type Config struct {
	Url string

	Logger Logger

	DisconnectRetry         int
	DisconnectRetryInterval time.Duration

	OnDisconnectedRetryFailed func(error)
}

type ConsumeErrFunc func(error)

type ConsumeFunc func([]byte) error

type Declaration struct {
	Exchanges []Exchange
	Queues    []Queue
}

type Exchange struct {
	Name       string
	Kind       string
	Durable    bool
	AutoDelete bool
	Internal   bool
	Nowait     bool
}

type Logger interface {
	Infof(string, ...interface{})
	Errorf(string, ...interface{})
}

type Queue struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	Nowait     bool
	Binds      []Bind
}

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