summaryrefslogtreecommitdiff
path: root/plugins/jobs/oooold/broker/amqp/config.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/oooold/broker/amqp/config.go')
-rw-r--r--plugins/jobs/oooold/broker/amqp/config.go39
1 files changed, 0 insertions, 39 deletions
diff --git a/plugins/jobs/oooold/broker/amqp/config.go b/plugins/jobs/oooold/broker/amqp/config.go
deleted file mode 100644
index 0ed3a50e..00000000
--- a/plugins/jobs/oooold/broker/amqp/config.go
+++ /dev/null
@@ -1,39 +0,0 @@
-package amqp
-
-import (
- "fmt"
- "github.com/spiral/roadrunner/service"
- "time"
-)
-
-// Config defines sqs broker configuration.
-type Config struct {
- // Addr of AMQP server (example: amqp://guest:guest@localhost:5672/).
- Addr string
-
- // Timeout to allocate the connection. Default 10 seconds.
- Timeout int
-}
-
-// Hydrate config values.
-func (c *Config) Hydrate(cfg service.Config) error {
- if err := cfg.Unmarshal(c); err != nil {
- return err
- }
-
- if c.Addr == "" {
- return fmt.Errorf("AMQP address is missing")
- }
-
- return nil
-}
-
-// TimeoutDuration returns number of seconds allowed to redial
-func (c *Config) TimeoutDuration() time.Duration {
- timeout := c.Timeout
- if timeout == 0 {
- timeout = 10
- }
-
- return time.Duration(timeout) * time.Second
-}