diff options
Diffstat (limited to 'crates/core/tedge/src/cli/connect/jwt_token.rs')
-rw-r--r-- | crates/core/tedge/src/cli/connect/jwt_token.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/crates/core/tedge/src/cli/connect/jwt_token.rs b/crates/core/tedge/src/cli/connect/jwt_token.rs index b81e26ed..afc86434 100644 --- a/crates/core/tedge/src/cli/connect/jwt_token.rs +++ b/crates/core/tedge/src/cli/connect/jwt_token.rs @@ -1,13 +1,13 @@ -use crate::cli::connect::{ConnectError, DEFAULT_HOST, RESPONSE_TIMEOUT}; +use crate::cli::connect::{ConnectError, RESPONSE_TIMEOUT}; use rumqttc::QoS::AtLeastOnce; use rumqttc::{Event, Incoming, MqttOptions, Outgoing, Packet}; -pub(crate) fn get_connected_c8y_url(port: u16) -> Result<String, ConnectError> { +pub(crate) fn get_connected_c8y_url(port: u16, host: String) -> Result<String, ConnectError> { const C8Y_TOPIC_BUILTIN_JWT_TOKEN_UPSTREAM: &str = "c8y/s/uat"; const C8Y_TOPIC_BUILTIN_JWT_TOKEN_DOWNSTREAM: &str = "c8y/s/dat"; const CLIENT_ID: &str = "get_jwt_token_c8y"; - let mut options = MqttOptions::new(CLIENT_ID, DEFAULT_HOST, port); + let mut options = MqttOptions::new(CLIENT_ID, host, port); options.set_keep_alive(RESPONSE_TIMEOUT); let (mut client, mut connection) = rumqttc::Client::new(options, 10); |