Skip to content

Commit 24de0d4

Browse files
committed
Return connection parameters from Pika/Stomp plugin activation
This means that the parameters are available on the configuration object, rather than having to go via the expected transport every time.
1 parent f54398e commit 24de0d4

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

src/workflows/util/zocalo/configuration.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@ def activate(configuration):
4848
("prefix", "--stomp-prfx"),
4949
]:
5050
StompTransport.defaults[target] = configuration[cfgoption]
51+
return dict(StompTransport.defaults)
5152

5253

5354
class Pika:
@@ -70,6 +71,7 @@ def activate(configuration):
7071
("vhost", "--rabbit-vhost"),
7172
]:
7273
PikaTransport.defaults[target] = configuration[cfgoption]
74+
return dict(PikaTransport.defaults)
7375

7476

7577
class DefaultTransport:

0 commit comments

Comments
 (0)