Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrClosed = errors.New("amqprpc: call closed")
View Source
var ErrConsumerUnready = errors.New("amqprpc: consumer unready")
View Source
var ErrNotDone = errors.New("amqprpc: call is not done")
View Source
var ErrPublisherUnready = errors.New("amqprpc: publisher unready")
View Source
var ErrReplyQueueGoneAway = errors.New("amqprpc: reply queue has gone away")
View Source
var ErrShutdown = errors.New("amqprpc: client is shut down")
Functions ¶
This section is empty.
Types ¶
type Call ¶
type Call struct { AutoAck bool // contains filtered or unexported fields }
func (*Call) Publishing ¶
func (call *Call) Publishing() amqpextra.Publishing
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
type Option ¶
type Option func(client *Client)
func WithConsumer ¶
func WithContext ¶
func WithPreFetchCount ¶
func WithReplyQueue ¶
func WithReplyQueue(rq ReplyQueue) Option
func WithShutdownPeriod ¶
func WithWorkerCount ¶
Click to show internal directories.
Click to hide internal directories.