Skip to content

Commit 61ac67b

Browse files
committed
initialise exchange with local admin account
1 parent e62decd commit 61ac67b

1 file changed

Lines changed: 14 additions & 6 deletions

File tree

tests/test_varys.py

Lines changed: 14 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -239,15 +239,23 @@ def setUp(self):
239239
"username": "guest2",
240240
"password": "guest",
241241
"amqp_url": "localhost",
242-
"port": 5671,
243-
"use_tls": True,
244-
"ca_certificate": ".rabbitmq/ca_certificate.pem",
245-
"client_certificate": ".rabbitmq/client_certificate.pem",
246-
"client_key": ".rabbitmq/client_key.pem",
247-
}
242+
"port": 5672,
243+
},
244+
"admin": {
245+
"username": "guest",
246+
"password": "guest",
247+
"amqp_url": "localhost",
248+
"port": 5672,
249+
"use_tls": False,
250+
},
248251
},
249252
}
250253

254+
# Setup exchange
255+
admin_varys = Varys("admin", LOG_FILENAME, config_path=TMP_FILENAME)
256+
admin_varys.send("setup message", "test-exchange", queue_suffix="test_queue")
257+
admin_varys.close()
258+
251259
with open(TMP_FILENAME, "w") as f:
252260
json.dump(config, f, ensure_ascii=False)
253261

0 commit comments

Comments
 (0)