Skip to content
This repository has been archived by the owner on Aug 16, 2023. It is now read-only.

Commit

Permalink
removed unicast subscription, changed shared unicast janus responses …
Browse files Browse the repository at this point in the history
…subscription to non-shared
  • Loading branch information
khodzha committed Nov 12, 2020
1 parent e418df4 commit 2fc263b
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions src/app/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -157,11 +157,6 @@ fn subscribe(agent: &mut Agent, agent_id: &AgentId, config: &Config) -> Result<J
)
.context("Error subscribing to multicast requests")?;

// Unicast requests
agent
.subscribe(&Subscription::unicast_requests(), QoS::AtMostOnce, None)
.context("Error subscribing to unicast requests")?;

// Janus status events
let subscription = Subscription::broadcast_events(&config.backend.id, API_VERSION, "status");

Expand All @@ -188,7 +183,7 @@ fn subscribe(agent: &mut Agent, agent_id: &AgentId, config: &Config) -> Result<J
let subscription = Subscription::unicast_responses_from(&config.backend.id);

agent
.subscribe(&subscription, QoS::AtLeastOnce, Some(&group))
.subscribe(&subscription, QoS::AtLeastOnce, None)
.context("Error subscribing to backend responses topic")?;

let janus_responses_topic = subscription
Expand Down

0 comments on commit 2fc263b

Please sign in to comment.