쿠 렌토 복합 코드

같은 사용자의 격자보기를 만들기 위해 복합 작업을하려고합니다. 다음 코드를 사용하고 있지만 그리드 대신 단일 출력을 제공합니다.

try {
         // 1. Media logic (webRtcEndpoint in loopback)
         MediaPipeline pipeline = kurento.createMediaPipeline();
         WebRtcEndpoint webRtcEndpoint1 = new WebRtcEndpoint.Builder(pipeline).build();
         WebRtcEndpoint webRtcEndpoint2 = new WebRtcEndpoint.Builder(pipeline).build();
         WebRtcEndpoint endpointOut = new WebRtcEndpoint.Builder(pipeline).build();
         Composite composite = new Composite.Builder(pipeline).build();
         HubPort hubPort1 = new HubPort.Builder(composite).build();
         HubPort hubPort2 = new HubPort.Builder(composite).build();
         HubPort out = new HubPort.Builder(composite).build();

         webRtcEndpoint1.connect(hubPort1);
         webRtcEndpoint2.connect(hubPort2);
         out.connect(endpointOut);
         // 2. Store user session
         UserSession user = new UserSession();
         user.setMediaPipeline(pipeline);
         user.setWebRtcEndpoint(endpointOut);
         users.put(session.getId(), user);
         // 3. SDP negotiation
         String sdpOffer = jsonMessage.get("sdpOffer").getAsString();
         String sdpAnswer = endpointOut.processOffer(sdpOffer);
         JsonObject response = new JsonObject();
         response.addProperty("id", "startResponse");
         response.addProperty("sdpAnswer", sdpAnswer);
         synchronized (session) {
            session.sendMessage(new TextMessage(response.toString()));
         }
         // 4. Gather ICE candidates
         endpointOut.addIceCandidateFoundListener(new EventListener<IceCandidateFoundEvent>() {
            @Override
            public void onEvent(IceCandidateFoundEvent event) {
               JsonObject response = new JsonObject();
               response.addProperty("id", "iceCandidate");
               response.add("candidate", JsonUtils.toJsonObject(event.getCandidate()));
               try {
                  synchronized (session) {
                     session.sendMessage(new TextMessage(response.toString()));
                  }
               } catch (IOException e) {
                  log.error(e.getMessage());
               }
            }
         });
         endpointOut.gatherCandidates();
      } catch (Throwable t) {
         sendError(session, t.getMessage());
      }

누구든지 도와주세요?

내가 작업하는 프로젝트는 kurento.org 웹 사이트에 제공된 hello world 예제와 동일합니다.