Examples of org.red5.server.api.stream.IClientStream.stop()

Class org.red5.server.api.stream.IClientStream

Examples of org.red5.server.api.stream.IClientStream.stop()

org.red5.server.api.stream.IClientStream.stop()
Stops scope handling (that is, stops application if given scope is app level scope and stops room handling if given scope has lower scope level). This method calls {@link ApplicationAdapter#appStop(IScope)} or{@link ApplicationAdapter#roomStop(IScope)} handlers respectively. @param scope Scope to stop

    if (!persistent) {
      assertTrue(so.isAcquired());
      so.release();
      assertFalse(so.isAcquired());
    }
    app.stop(appScope);


    //    IScope room1 = ScopeUtils.resolveScope(appScope, "/junit/room1");
    //    IScope room4 = ScopeUtils.resolveScope(appScope, "/junit/room1/room4");
    //    log.debug("Room 4 scope: {}", room4);
    //    assertTrue(room4.getDepth() == 3);

View Full Code Here

    log.debug("Worker: {} shared object: {}", soa.getId(), soa.getSharedObject().getAttributes());
    ScopeClientWorkerB sob = (ScopeClientWorkerB) trs[1];
    log.debug("Worker: {} shared object: {}", sob.getId(), sob.getSharedObject().getAttributes());
    Thread.sleep(300L);
    // clean up / stop
    app.stop(appScope);
  }


  // Used to ensure all the test-runnables are in "runTest" block.
  private static boolean allThreadsRunning() {
    for (TestRunnable r : trs) {

View Full Code Here

      if (conn instanceof IStreamCapableConnection) {
        IStreamCapableConnection streamConn = (IStreamCapableConnection) conn;
        int streamId = conn.getStreamId();
        IClientStream stream = streamConn.getStreamById(streamId);
        if (stream != null) {
          stream.stop();
        }
      }
    }
  }

View Full Code Here

      }
      IStreamCapableConnection streamConn = (IStreamCapableConnection) conn;
      int streamId = getCurrentStreamId();
      IClientStream stream = streamConn.getStreamById(streamId);
      if (stream != null) {
        stream.stop();
      }
    }
  }


  /** {@inheritDoc} */

View Full Code Here

    if (rc.getIsScreenClient() && publishName != null) {
          IScope scope = current.getScope();
          IBroadcastStream stream = getBroadcastStream(scope, publishName);
      StreamingProxy proxy = streamingProxyMap.remove(publishName);
      if (proxy != null) {
        proxy.stop();
        IBroadcastScope bsScope = getBroadcastScope(scope, stream.getPublishedName());
        if (bsScope != null) {
          bsScope.unsubscribe(proxy);
        }
      }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.