diff --git a/src/main/java/im/rosetta/service/services/ForwardUnitService.java b/src/main/java/im/rosetta/service/services/ForwardUnitService.java index d3b349a..afa52f1 100644 --- a/src/main/java/im/rosetta/service/services/ForwardUnitService.java +++ b/src/main/java/im/rosetta/service/services/ForwardUnitService.java @@ -138,6 +138,14 @@ public class ForwardUnitService { e.printStackTrace(); } }); + connection.setOfferConsumer(arg0 -> { + try{ + onSdpOffer(arg0); + }catch(ProtocolException e){ + this.logger.error(Color.RED + "Failed to retranslate SDP offer from SFU server: " + address + ", error: " + e.getMessage()); + e.printStackTrace(); + } + }); this.sfuConnections.add(connection); this.logger.info(Color.GREEN + "Successfully connected to SFU server: " + address); } catch (Exception e) {