Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Factory ¶ added in v0.7.0
type Factory struct {
// contains filtered or unexported fields
}
Factory of a AMQP consumer
type OptionFunc ¶ added in v0.4.3
type OptionFunc func(*consumer) error
OptionFunc definition for configuring the consumer in a functional way.
func Buffer ¶ added in v0.4.3
func Buffer(buf int) OptionFunc
Buffer option for adjusting the incoming messages buffer.
func Requeue ¶ added in v0.4.3
func Requeue(requeue bool) OptionFunc
Requeue option for adjusting the requeue policy of a message.
func Timeout ¶ added in v0.4.3
func Timeout(timeout time.Duration) OptionFunc
Timeout option for adjusting the timeout of the connection.
Click to show internal directories.
Click to hide internal directories.