[INFO] fetching crate crabbyq 1.0.0...
[INFO] testing crabbyq-1.0.0 against 1.99.0-beta.8+cargoflags=--release for beta-release-1.100-2
[INFO] extracting crate crabbyq 1.0.0 into /workspace/builds/worker-0-tc1/source
[INFO] started tweaking crates.io crate crabbyq 1.0.0
[INFO] removed 0 missing examples
[INFO] removed 0 missing tests
[INFO] finished tweaking crates.io crate crabbyq 1.0.0
[INFO] tweaked toml for crates.io crate crabbyq 1.0.0 written to /workspace/builds/worker-0-tc1/source/Cargo.toml
[INFO] validating manifest of crates.io crate crabbyq 1.0.0 on toolchain 1.99.0-beta.8
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.99.0-beta.8" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate crabbyq 1.0.0 already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.99.0-beta.8" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded serde_nanos v0.1.4
[INFO] [stderr]   Downloaded rustls-native-certs v0.7.3
[INFO] [stderr]   Downloaded tryhard v0.5.2
[INFO] [stderr]   Downloaded nuid v0.5.0
[INFO] [stderr]   Downloaded deranged v0.5.3
[INFO] [stderr]   Downloaded nkeys v0.4.5
[INFO] [stderr]   Downloaded rustls-webpki v0.102.8
[INFO] [stderr]   Downloaded rumqttc v0.25.1
[INFO] [stderr]   Downloaded time v0.3.43
[INFO] [stderr]   Downloaded signatory v0.27.1
[INFO] [stderr]   Downloaded tokio-websockets v0.10.1
[INFO] [stderr]   Downloaded redis v0.32.7
[INFO] [stderr]   Downloaded async-nats v0.46.0
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:77db811e55d90add9212f6832c23229e3de5f1c1f9905e8cb07319ea15df73ac" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e
[INFO] running `Command { std: "docker" "start" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-w" "/opt/rustwide/workdir" "--user" "0:0" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "build" "--frozen" "--message-format=json" "--release", kill_on_drop: false }`
[INFO] [stderr]    Compiling libc v0.2.175
[INFO] [stderr]    Compiling serde_json v1.0.143
[INFO] [stderr]    Compiling anyhow v1.0.99
[INFO] [stderr]    Compiling memchr v2.7.5
[INFO] [stderr]    Compiling proc-macro2 v1.0.101
[INFO] [stderr]    Compiling serde v1.0.219
[INFO] [stderr]    Compiling sync_wrapper v1.0.2
[INFO] [stderr]    Compiling quote v1.0.40
[INFO] [stderr]    Compiling syn v2.0.106
[INFO] [stderr]    Compiling mio v1.0.4
[INFO] [stderr]    Compiling signal-hook-registry v1.4.5
[INFO] [stderr]    Compiling futures-macro v0.3.31
[INFO] [stderr]    Compiling serde_derive v1.0.219
[INFO] [stderr]    Compiling tokio-macros v2.6.0
[INFO] [stderr]    Compiling tracing-attributes v0.1.31
[INFO] [stderr]    Compiling async-trait v0.1.89
[INFO] [stderr]    Compiling tokio v1.49.0
[INFO] [stderr]    Compiling futures-util v0.3.31
[INFO] [stderr]    Compiling tracing v0.1.44
[INFO] [stderr]    Compiling tower v0.5.3
[INFO] [stderr]    Compiling crabbyq v1.0.0 (/opt/rustwide/workdir)
[INFO] [stderr]     Finished `release` profile [optimized] target(s) in 22.13s
[INFO] running `Command { std: "docker" "inspect" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "test" "--frozen" "--no-run" "--message-format=json" "--release", kill_on_drop: false }`
[INFO] [stderr]    Compiling tracing-core v0.1.36
[INFO] [stderr]    Compiling log v0.4.28
[INFO] [stderr]    Compiling cfg-if v1.0.3
[INFO] [stderr]    Compiling nu-ansi-term v0.50.1
[INFO] [stderr]    Compiling tokio v1.49.0
[INFO] [stderr]    Compiling thread_local v1.1.9
[INFO] [stderr]    Compiling tracing v0.1.44
[INFO] [stderr]    Compiling tracing-log v0.2.0
[INFO] [stderr]    Compiling tracing-subscriber v0.3.22
[INFO] [stderr]    Compiling crabbyq v1.0.0 (/opt/rustwide/workdir)
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/basic_state.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/extractors.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/jetstream.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::MqttBroker`
[INFO] [stdout]   --> examples/basic_mqtt.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::MqttBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `MqttBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:11:15
[INFO] [stdout]    |
[INFO] [stdout] 10 | #[cfg(feature = "mqtt")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `mqtt` feature
[INFO] [stdout] 11 | pub use mqtt::MqttBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `rumqttc`
[INFO] [stdout]  --> examples/basic_mqtt.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use rumqttc::MqttOptions;
[INFO] [stdout]   |     ^^^^^^^ use of unresolved module or unlinked crate `rumqttc`
[INFO] [stdout]   |
[INFO] [stdout]   = help: if you wanted to use a crate named `rumqttc`, use `cargo add rumqttc` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/basic_rpc.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/basic.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0531]: cannot find tuple struct or tuple variant `Cbor` in this scope
[INFO] [stdout]   --> examples/extractors.rs:69:22
[INFO] [stdout]    |
[INFO] [stdout] 69 | async fn handle_cbor(Cbor(payload): Cbor<CborPayload>) -> CrabbyResult<()> {
[INFO] [stdout]    |                      ^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find type `Cbor` in this scope
[INFO] [stdout]   --> examples/extractors.rs:69:37
[INFO] [stdout]    |
[INFO] [stdout] 69 | async fn handle_cbor(Cbor(payload): Cbor<CborPayload>) -> CrabbyResult<()> {
[INFO] [stdout]    |                                     ^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/basic_state.rs:36:23
[INFO] [stdout]    |
[INFO] [stdout] 36 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::RedisBroker`
[INFO] [stdout]   --> examples/basic_redis.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::RedisBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^-----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `RedisBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:15:16
[INFO] [stdout]    |
[INFO] [stdout] 14 | #[cfg(feature = "redis")]
[INFO] [stdout]    |       ----------------- the item is gated behind the `redis` feature
[INFO] [stdout] 15 | pub use redis::RedisBroker;
[INFO] [stdout]    |                ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/jetstream.rs:52:21
[INFO] [stdout]    |
[INFO] [stdout] 52 |     let jetstream = async_nats::jetstream::new(nats_client);
[INFO] [stdout]    |                     ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> tests/nats_integration.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `MqttPublisher` in this scope
[INFO] [stdout]   --> examples/basic_mqtt.rs:20:21
[INFO] [stdout]    |
[INFO] [stdout] 20 |     let publisher = MqttPublisher::new(broker.clone());
[INFO] [stdout]    |                     ^^^^^^^^^^^^^ use of undeclared type `MqttPublisher`
[INFO] [stdout]    |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]    |
[INFO] [stdout] 20 -     let publisher = MqttPublisher::new(broker.clone());
[INFO] [stdout] 20 +     let publisher = Publisher::new(broker.clone());
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/middleware.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "basic_state") due to 2 previous errors
[INFO] [stderr] warning: build failed, waiting for other jobs to finish...
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/multirouter.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/publishers.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/basic_rpc.rs:31:23
[INFO] [stdout]    |
[INFO] [stdout] 31 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/custom_error_rpc.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/jetstream.rs:54:31
[INFO] [stdout]    |
[INFO] [stdout] 54 |         .get_or_create_stream(async_nats::jetstream::stream::Config {
[INFO] [stdout]    |                               ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> tests/nats_integration.rs:86:21
[INFO] [stdout]    |
[INFO] [stdout] 86 |     let jetstream = async_nats::jetstream::new(client.clone());
[INFO] [stdout]    |                     ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `redis` in this scope
[INFO] [stdout]   --> examples/basic_redis.rs:15:18
[INFO] [stdout]    |
[INFO] [stdout] 15 |     let client = redis::Client::open("redis://127.0.0.1:6379")?;
[INFO] [stdout]    |                  ^^^^^ use of unresolved module or unlinked crate `redis`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `redis`, use `cargo add redis` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> tests/nats_integration.rs:93:31
[INFO] [stdout]    |
[INFO] [stdout] 93 |         .get_or_create_stream(async_nats::jetstream::stream::Config {
[INFO] [stdout]    |                               ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/basic.rs:19:23
[INFO] [stdout]    |
[INFO] [stdout] 19 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/jetstream.rs:57:24
[INFO] [stdout]    |
[INFO] [stdout] 57 |             retention: async_nats::jetstream::stream::RetentionPolicy::WorkQueue,
[INFO] [stdout]    |                        ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/multirouter.rs:30:23
[INFO] [stdout]    |
[INFO] [stdout] 30 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/jetstream.rs:58:22
[INFO] [stdout]    |
[INFO] [stdout] 58 |             storage: async_nats::jetstream::stream::StorageType::Memory,
[INFO] [stdout]    |                      ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> tests/nats_integration.rs:96:24
[INFO] [stdout]    |
[INFO] [stdout] 96 |             retention: async_nats::jetstream::stream::RetentionPolicy::WorkQueue,
[INFO] [stdout]    |                        ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "basic_mqtt") due to 3 previous errors
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "basic") due to 2 previous errors
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/middleware.rs:55:23
[INFO] [stdout]    |
[INFO] [stdout] 55 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/jetstream.rs:45:23
[INFO] [stdout]    |
[INFO] [stdout] 45 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method call on a diverging inference variable
[INFO] [stdout]   --> examples/jetstream.rs:46:51
[INFO] [stdout]    |
[INFO] [stdout] 46 |     let nats_broker = NatsBroker::new(nats_client.clone());
[INFO] [stdout]    |                                                   ^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider providing a type annotation
[INFO] [stdout]    = warning: this was previously accepted by the compiler but is being phased out; it will become a hard error in a future release!
[INFO] [stdout]    = note: for more information, see issue #156047 <https://github.com/rust-lang/rust/issues/156047>
[INFO] [stdout]    = note: `#[warn(method_call_on_diverging_infer_var)]` (part of `#[warn(future_incompatible)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable call
[INFO] [stdout]   --> examples/jetstream.rs:46:23
[INFO] [stdout]    |
[INFO] [stdout] 46 |     let nats_broker = NatsBroker::new(nats_client.clone());
[INFO] [stdout]    |                       ^^^^^^^^^^^^^^^ ------------------- any code following this expression is unreachable
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       unreachable call
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unreachable_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `NatsPublisher` in this scope
[INFO] [stdout]   --> examples/jetstream.rs:47:21
[INFO] [stdout]    |
[INFO] [stdout] 47 |     let publisher = NatsPublisher::new(nats_broker.clone());
[INFO] [stdout]    |                     ^^^^^^^^^^^^^ use of undeclared type `NatsPublisher`
[INFO] [stdout]    |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]    |
[INFO] [stdout] 47 -     let publisher = NatsPublisher::new(nats_broker.clone());
[INFO] [stdout] 47 +     let publisher = Publisher::new(nats_broker.clone());
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable call
[INFO] [stdout]   --> examples/jetstream.rs:52:21
[INFO] [stdout]    |
[INFO] [stdout] 52 |     let jetstream = async_nats::jetstream::new(nats_client);
[INFO] [stdout]    |                     ^^^^^^^^^^^^^^^^^^^^^^^^^^ ----------- any code following this expression is unreachable
[INFO] [stdout]    |                     |
[INFO] [stdout]    |                     unreachable call
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method call on a diverging inference variable
[INFO] [stdout]   --> examples/jetstream.rs:65:21
[INFO] [stdout]    |
[INFO] [stdout] 65 |     commands_stream.purge().await?;
[INFO] [stdout]    |                     ^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider providing a type annotation
[INFO] [stdout]    = warning: this was previously accepted by the compiler but is being phased out; it will become a hard error in a future release!
[INFO] [stdout]    = note: for more information, see issue #156047 <https://github.com/rust-lang/rust/issues/156047>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/publishers.rs:39:23
[INFO] [stdout]    |
[INFO] [stdout] 39 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> tests/nats_integration.rs:97:22
[INFO] [stdout]    |
[INFO] [stdout] 97 |             storage: async_nats::jetstream::stream::StorageType::Memory,
[INFO] [stdout]    |                      ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/extractors.rs:84:23
[INFO] [stdout]    |
[INFO] [stdout] 84 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `crabbyq::brokers::NatsBroker`
[INFO] [stdout]   --> examples/graceful_shutdown.rs:1:5
[INFO] [stdout]    |
[INFO] [stdout]  1 | use crabbyq::brokers::NatsBroker;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^----------
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       no `NatsBroker` in `brokers`
[INFO] [stdout]    |
[INFO] [stdout] note: found an item that was configured out
[INFO] [stdout]   --> src/brokers/mod.rs:13:15
[INFO] [stdout]    |
[INFO] [stdout] 12 | #[cfg(feature = "nats")]
[INFO] [stdout]    |       ---------------- the item is gated behind the `nats` feature
[INFO] [stdout] 13 | pub use nats::NatsBroker;
[INFO] [stdout]    |               ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `RedisPublisher` in this scope
[INFO] [stdout]   --> examples/basic_redis.rs:17:21
[INFO] [stdout]    |
[INFO] [stdout] 17 |     let publisher = RedisPublisher::new(broker.clone());
[INFO] [stdout]    |                     ^^^^^^^^^^^^^^ use of undeclared type `RedisPublisher`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "publishers") due to 2 previous errors
[INFO] [stderr] error: could not compile `crabbyq` (example "multirouter") due to 2 previous errors
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "basic_rpc") due to 2 previous errors
[INFO] [stderr] error: could not compile `crabbyq` (example "middleware") due to 2 previous errors
[INFO] [stdout] error[E0599]: no method named `purge` found for type `!` in the current scope
[INFO] [stdout]   --> examples/jetstream.rs:65:21
[INFO] [stdout]    |
[INFO] [stdout] 65 |     commands_stream.purge().await?;
[INFO] [stdout]    |                     ^^^^^ method not found in `!`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `NatsRouter` in this scope
[INFO] [stdout]   --> examples/jetstream.rs:71:15
[INFO] [stdout]    |
[INFO] [stdout] 71 |     let app = NatsRouter::new()
[INFO] [stdout]    |               ^^^^^^^^^^ use of undeclared type `NatsRouter`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable call
[INFO] [stdout]   --> examples/jetstream.rs:72:10
[INFO] [stdout]    |
[INFO] [stdout] 72 |         .jetstream(commands_stream)
[INFO] [stdout]    |          ^^^^^^^^^ --------------- any code following this expression is unreachable
[INFO] [stdout]    |          |
[INFO] [stdout]    |          unreachable call
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/custom_error_rpc.rs:71:23
[INFO] [stdout]    |
[INFO] [stdout] 71 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> examples/graceful_shutdown.rs:24:23
[INFO] [stdout]    |
[INFO] [stdout] 24 |     let nats_client = async_nats::connect("nats://localhost:4222").await?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "basic_redis") due to 3 previous errors
[INFO] [stdout] Some errors have detailed explanations: E0425, E0432, E0433, E0531.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0425`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "extractors") due to 4 previous errors
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> tests/nats_integration.rs:44:18
[INFO] [stdout]    |
[INFO] [stdout] 44 |     let client = async_nats::connect("nats://127.0.0.1:4222").await?;
[INFO] [stdout]    |                  ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method call on a diverging inference variable
[INFO] [stdout]   --> tests/nats_integration.rs:47:41
[INFO] [stdout]    |
[INFO] [stdout] 47 |     let broker = NatsBroker::new(client.clone());
[INFO] [stdout]    |                                         ^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider providing a type annotation
[INFO] [stdout]    = warning: this was previously accepted by the compiler but is being phased out; it will become a hard error in a future release!
[INFO] [stdout]    = note: for more information, see issue #156047 <https://github.com/rust-lang/rust/issues/156047>
[INFO] [stdout]    = note: `#[warn(method_call_on_diverging_infer_var)]` (part of `#[warn(future_incompatible)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable call
[INFO] [stdout]   --> tests/nats_integration.rs:47:18
[INFO] [stdout]    |
[INFO] [stdout] 47 |     let broker = NatsBroker::new(client.clone());
[INFO] [stdout]    |                  ^^^^^^^^^^^^^^^ -------------- any code following this expression is unreachable
[INFO] [stdout]    |                  |
[INFO] [stdout]    |                  unreachable call
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unreachable_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433, E0599.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "jetstream") due to 9 previous errors; 7 warnings emitted
[INFO] [stdout] error[E0433]: cannot find module or crate `async_nats` in this scope
[INFO] [stdout]   --> tests/nats_integration.rs:85:18
[INFO] [stdout]    |
[INFO] [stdout] 85 |     let client = async_nats::connect("nats://127.0.0.1:4222").await?;
[INFO] [stdout]    |                  ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats`
[INFO] [stdout]    |
[INFO] [stdout]    = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method call on a diverging inference variable
[INFO] [stdout]   --> tests/nats_integration.rs:86:55
[INFO] [stdout]    |
[INFO] [stdout] 86 |     let jetstream = async_nats::jetstream::new(client.clone());
[INFO] [stdout]    |                                                       ^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider providing a type annotation
[INFO] [stdout]    = warning: this was previously accepted by the compiler but is being phased out; it will become a hard error in a future release!
[INFO] [stdout]    = note: for more information, see issue #156047 <https://github.com/rust-lang/rust/issues/156047>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable call
[INFO] [stdout]   --> tests/nats_integration.rs:86:21
[INFO] [stdout]    |
[INFO] [stdout] 86 |     let jetstream = async_nats::jetstream::new(client.clone());
[INFO] [stdout]    |                     ^^^^^^^^^^^^^^^^^^^^^^^^^^ -------------- any code following this expression is unreachable
[INFO] [stdout]    |                     |
[INFO] [stdout]    |                     unreachable call
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method call on a diverging inference variable
[INFO] [stdout]    --> tests/nats_integration.rs:101:12
[INFO] [stdout]     |
[INFO] [stdout] 101 |     stream.purge().await?;
[INFO] [stdout]     |            ^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider providing a type annotation
[INFO] [stdout]     = warning: this was previously accepted by the compiler but is being phased out; it will become a hard error in a future release!
[INFO] [stdout]     = note: for more information, see issue #156047 <https://github.com/rust-lang/rust/issues/156047>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `purge` found for type `!` in the current scope
[INFO] [stdout]    --> tests/nats_integration.rs:101:12
[INFO] [stdout]     |
[INFO] [stdout] 101 |     stream.purge().await?;
[INFO] [stdout]     |            ^^^^^ method not found in `!`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable call
[INFO] [stdout]    --> tests/nats_integration.rs:103:18
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let broker = NatsBroker::new(client);
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^ ------ any code following this expression is unreachable
[INFO] [stdout]     |                  |
[INFO] [stdout]     |                  unreachable call
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `NatsPublisher` in this scope
[INFO] [stdout]    --> tests/nats_integration.rs:104:21
[INFO] [stdout]     |
[INFO] [stdout] 104 |     let publisher = NatsPublisher::new(broker.clone());
[INFO] [stdout]     |                     ^^^^^^^^^^^^^ use of undeclared type `NatsPublisher`
[INFO] [stdout]     |
[INFO] [stdout] help: a struct with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 104 -     let publisher = NatsPublisher::new(broker.clone());
[INFO] [stdout] 104 +     let publisher = Publisher::new(broker.clone());
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: cannot find type `NatsRouter` in this scope
[INFO] [stdout]    --> tests/nats_integration.rs:107:15
[INFO] [stdout]     |
[INFO] [stdout] 107 |     let app = NatsRouter::new()
[INFO] [stdout]     |               ^^^^^^^^^^ use of undeclared type `NatsRouter`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable call
[INFO] [stdout]    --> tests/nats_integration.rs:109:10
[INFO] [stdout]     |
[INFO] [stdout] 109 |         .jetstream(stream)
[INFO] [stdout]     |          ^^^^^^^^^ ------ any code following this expression is unreachable
[INFO] [stdout]     |          |
[INFO] [stdout]     |          unreachable call
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "graceful_shutdown") due to 2 previous errors
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (example "custom_error_rpc") due to 2 previous errors
[INFO] [stdout] Some errors have detailed explanations: E0432, E0433, E0599.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0432`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `crabbyq` (test "nats_integration") due to 10 previous errors; 10 warnings emitted
[INFO] running `Command { std: "docker" "inspect" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e", kill_on_drop: false }`
[INFO] [stdout] f28df95b06f99ac74cf3b00f231b9138fd0a36d158d5c3fadea6c21ecaaeb77e
