Skip to content

Commit

Permalink
Merge pull request #2944 from tediou5/opt/remove-unnecessary-queue-gr…
Browse files Browse the repository at this point in the history
…oup-for-farmer-identify-broadcast

opt: remove unnecessary queue group setup when subscribe to farmer identify broadcast
  • Loading branch information
nazar-pc authored Jul 24, 2024
2 parents 5d3be70 + 67edf29 commit ee46fa7
Showing 1 changed file with 1 addition and 8 deletions.
9 changes: 1 addition & 8 deletions crates/subspace-farmer/src/cluster/farmer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -509,14 +509,7 @@ async fn identify_responder(
identification_broadcast_interval: Duration,
) -> anyhow::Result<()> {
let mut subscription = nats_client
.subscribe_to_broadcasts::<ClusterControllerFarmerIdentifyBroadcast>(
None,
// Use the first farm as a queue group. Doesn't matter what we use, just needs to be
// deterministic.
farms_details
.first()
.map(|farm_details| farm_details.farm_id_string.clone()),
)
.subscribe_to_broadcasts::<ClusterControllerFarmerIdentifyBroadcast>(None, None)
.await
.map_err(|error| {
anyhow!("Failed to subscribe to farmer identify broadcast requests: {error}")
Expand Down

0 comments on commit ee46fa7

Please sign in to comment.