diff --git a/roles/jd-client/src/lib/mod.rs b/roles/jd-client/src/lib/mod.rs index 7e2fe7edc8..db52a6c396 100644 --- a/roles/jd-client/src/lib/mod.rs +++ b/roles/jd-client/src/lib/mod.rs @@ -261,12 +261,6 @@ impl JobDeclaratorClient { } }; - // Start receiving messages from the SV2 Upstream role - if let Err(e) = upstream_sv2::Upstream::parse_incoming(upstream.clone()) { - error!("failed to create sv2 parser: {}", e); - panic!() - } - match upstream_sv2::Upstream::setup_connection( upstream.clone(), proxy_config.min_supported_version, @@ -281,6 +275,12 @@ impl JobDeclaratorClient { } } + // Start receiving messages from the SV2 Upstream role + if let Err(e) = upstream_sv2::Upstream::parse_incoming(upstream.clone()) { + error!("failed to create sv2 parser: {}", e); + panic!() + } + // Format `Downstream` connection address let downstream_addr = SocketAddr::new( IpAddr::from_str(&proxy_config.downstream_address).unwrap(),