summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-23 09:50:41 +0300
committerValery Piashchynski <[email protected]>2021-07-23 09:50:41 +0300
commitf585c654027f6dc40d7e3a3cdf7906006ed2427a (patch)
treeedddc0ebdde5b1e4d4a95f1593cd3ede28de0cfe
parentc851b5611a4118b714a05873225916ae07cf4e4a (diff)
Use zap logger in AMQP tests instead of mocked (temporarly)
Signed-off-by: Valery Piashchynski <[email protected]>
-rw-r--r--plugins/jobs/drivers/amqp/config.go2
-rw-r--r--tests/plugins/jobs/jobs_amqp_test.go3
2 files changed, 3 insertions, 2 deletions
diff --git a/plugins/jobs/drivers/amqp/config.go b/plugins/jobs/drivers/amqp/config.go
index 2a1aed20..37f5c1c4 100644
--- a/plugins/jobs/drivers/amqp/config.go
+++ b/plugins/jobs/drivers/amqp/config.go
@@ -43,7 +43,7 @@ func (c *Config) InitDefault() {
}
if c.Exchange == "" {
- c.Exchange = "default"
+ c.Exchange = "amqp.default"
}
if c.Prefetch == 0 {
diff --git a/tests/plugins/jobs/jobs_amqp_test.go b/tests/plugins/jobs/jobs_amqp_test.go
index a95ac98b..8f87072b 100644
--- a/tests/plugins/jobs/jobs_amqp_test.go
+++ b/tests/plugins/jobs/jobs_amqp_test.go
@@ -58,7 +58,8 @@ func TestAMQPInit(t *testing.T) {
cfg,
&server.Plugin{},
&rpcPlugin.Plugin{},
- mockLogger,
+ &logger.ZapLogger{},
+ // mockLogger,
&jobs.Plugin{},
&resetter.Plugin{},
&informer.Plugin{},