diff --git a/lib/Myriad/Commands.pm b/lib/Myriad/Commands.pm index 5d519605..6b420c4e 100644 --- a/lib/Myriad/Commands.pm +++ b/lib/Myriad/Commands.pm @@ -76,6 +76,14 @@ async method service (@args) { } } + # Ensure we have valid transports in place before we start + for my $type (qw(storage subscription rpc)) { + $log->tracef('Set up transport for [%s]', $type); + my $method = $myriad->config->${\"${type}_transport"}->as_string . '_transport'; + my $instance = $myriad->$method; + await $instance->start if $instance->can('start'); + } + # Load services into Myriad but don't start them yet $log->tracef('Attempt to add services for %s', join ',', @services_modules);