We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3e47841 commit b4427fcCopy full SHA for b4427fc
src/murfey/cli/repost_failed_calls.py
@@ -26,6 +26,7 @@
26
import murfey.server.api.websocket
27
import murfey.server.api.workflow
28
from murfey.server.murfey_db import url
29
+from murfey.server.run import _set_up_transport
30
from murfey.util.config import security_from_file
31
32
@@ -178,8 +179,10 @@ def run():
178
179
)
180
args = parser.parse_args()
181
- # Read the security config file
182
+ # Read the security config file and configure the transport
183
security_config = security_from_file(args.config)
184
+ PikaTransport().load_configuration_file(security_config.rabbitmq_credentials)
185
+ _set_up_transport("PikaTransport")
186
187
# Purge the queue and repost/reinject any messages found
188
dlq_dump_path = Path(args.dir)
0 commit comments