diff --git a/async-nats/src/service/mod.rs b/async-nats/src/service/mod.rs index c1dcdc25f..63924ca40 100644 --- a/async-nats/src/service/mod.rs +++ b/async-nats/src/service/mod.rs @@ -639,7 +639,7 @@ impl Group { queue_group: Z, ) -> Group { Group { - prefix: prefix.to_string(), + prefix: format!("{}.{}", self.prefix.to_string(), prefix.to_string()), stats: self.stats.clone(), client: self.client.clone(), shutdown_tx: self.shutdown_tx.clone(),