Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Exchange ¶ added in v0.24.0
type Exchange struct {
// contains filtered or unexported fields
}
Exchange represents an AMQP exchange.
func NewExchange ¶ added in v0.24.0
NewExchange validates its input and creates a new Exchange. name should be a non empty string, kind should be one of: [direct, fanout, topic, headers].
type Factory ¶ added in v0.23.0
type Factory struct {
// contains filtered or unexported fields
}
Factory of an 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 Bindings ¶ added in v0.24.0
func Bindings(bindings ...string) OptionFunc
Bindings option for providing custom exchange-queue bindings.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.