diff --git a/src/connection.rs b/src/connection.rs index 6a3d7a5..9a980f8 100644 --- a/src/connection.rs +++ b/src/connection.rs @@ -1153,21 +1153,14 @@ impl ConnectionManager { match session .create_subscription( Duration::from_secs(1), - 120, - 10, + 15, + 5, 0, 0, true, opcua::client::SubscriptionCallbacks::new( move |notification| { if notification.status.is_bad() { - if notification.status == opcua::types::StatusCode::BadTimeout { - tracing::warn!( - "Subscription publish timeout for source {}, waiting for heartbeat validation before reconnect", - current_source_id - ); - return; - } tracing::warn!( "Subscription status changed to {:?} for source {}, triggering reconnection", notification.status,