You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
47 lines
1.4 KiB
47 lines
1.4 KiB
package rabbitmq
|
|
|
|
import "time"
|
|
|
|
// ConnectionOptions are used to describe how a new consumer will be created.
|
|
type ConnectionOptions struct {
|
|
ReconnectInterval time.Duration
|
|
Logger Logger
|
|
Config Config
|
|
}
|
|
|
|
// getDefaultConnectionOptions describes the options that will be used when a value isn't provided
|
|
func getDefaultConnectionOptions() ConnectionOptions {
|
|
return ConnectionOptions{
|
|
ReconnectInterval: time.Second * 5,
|
|
Logger: stdDebugLogger{},
|
|
Config: Config{},
|
|
}
|
|
}
|
|
|
|
// WithConnectionOptionsReconnectInterval sets the reconnection interval
|
|
func WithConnectionOptionsReconnectInterval(interval time.Duration) func(options *ConnectionOptions) {
|
|
return func(options *ConnectionOptions) {
|
|
options.ReconnectInterval = interval
|
|
}
|
|
}
|
|
|
|
// WithConnectionOptionsLogging sets logging to true on the consumer options
|
|
// and sets the
|
|
func WithConnectionOptionsLogging(options *ConnectionOptions) {
|
|
options.Logger = stdDebugLogger{}
|
|
}
|
|
|
|
// WithConnectionOptionsLogger sets logging to true on the consumer options
|
|
// and sets the
|
|
func WithConnectionOptionsLogger(log Logger) func(options *ConnectionOptions) {
|
|
return func(options *ConnectionOptions) {
|
|
options.Logger = log
|
|
}
|
|
}
|
|
|
|
// WithConnectionOptionsConfig sets the Config used in the connection
|
|
func WithConnectionOptionsConfig(cfg Config) func(options *ConnectionOptions) {
|
|
return func(options *ConnectionOptions) {
|
|
options.Config = cfg
|
|
}
|
|
}
|