Update to use SinkExt components

Signed-off-by: Stephen Wakely <[email protected]>

Cargo.toml

@@ -300,7 +300,7 @@ rdkafka = { version = "0.35.0", default-features = false, features = ["tokio", "
 redis = { version = "0.24.0", default-features = false, features = ["connection-manager", "tokio-comp", "tokio-native-tls-comp"], optional = true }
 regex = { version = "1.10.2", default-features = false, features = ["std", "perf"] }
 roaring = { version = "0.10.2", default-features = false, optional = true }
-rumqttc = { version = "0.20.0", default-features = false, features = ["use-rustls"], optional = true }
+rumqttc = { version = "0.23.0", default-features = false, features = ["use-rustls"], optional = true }
 seahash = { version = "4.1.0", default-features = false }
 semver = { version = "1.0.21", default-features = false, features = ["serde", "std"], optional = true }
 smallvec = { version = "1", default-features = false, features = ["union", "serde"] }

scripts/integration/mqtt/test.yaml

@@ -1,8 +1,11 @@
-args:
-- --features
+features:
 - mqtt-integration-tests
-- --lib
-- '::mqtt::'
+
+test_filter: '::mqtt::'
 
 matrix:
   version: ['5.0.15']
+
+paths:
+- "src/internal_events/mqtt.rs"
+- "src/sinks/mqtt/**"

src/internal_events/mod.rs

@@ -87,10 +87,6 @@ mod lua;
 mod metric_to_log;
 #[cfg(feature = "sources-mongodb_metrics")]
 mod mongodb_metrics;
-#[cfg(feature = "sinks-mqtt")]
-mod mqtt;
-#[cfg(feature = "sinks-nats")]
-mod nats;
 #[cfg(feature = "sources-nginx_metrics")]
 mod nginx_metrics;
 mod open;
@@ -225,10 +221,6 @@ pub(crate) use self::loki::*;
 pub(crate) use self::lua::*;
 #[cfg(feature = "transforms-metric_to_log")]
 pub(crate) use self::metric_to_log::*;
-#[cfg(feature = "sinks-mqtt")]
-pub(crate) use self::mqtt::*;
-#[cfg(feature = "sinks-nats")]
-pub(crate) use self::nats::*;
 #[cfg(feature = "sources-nginx_metrics")]
 pub(crate) use self::nginx_metrics::*;
 #[allow(unused_imports)]