Package org.red5.server.api.service

Examples of org.red5.server.api.service.IServiceCapableConnection.invoke()

809
810
811
812
813
814
815
816
817
818
819
                if (rcl.getIsScreenClient() != null && rcl.getIsScreenClient()) {
                  // continue;
                } else {
                  log.debug("is this users still alive? :" + rcl);
                  IServiceCapableConnection iStream = (IServiceCapableConnection) conn;
                  iStream.invoke(clientFunction, new Object[] { rc }, this);
                }

                log.debug("sending notification to " + conn + " ID: ");

                // if this close stream event then stop the
View Full Code Here
375
376
377
378
379
380
381
382
383
384
385
    log.info("callclient called");
    IConnection conn = Red5.getConnectionLocal();
    if (conn instanceof IServiceCapableConnection) {
        IServiceCapableConnection sc = (IServiceCapableConnection) conn;
        log.info("flashmethod called");
        sc.invoke("flashmethod", new Object[]{"One", 1});
    }
  }
  public boolean appConnect( IConnection conn , Object[] params )
  { 
    //String id=conn.getClient().getId();
View Full Code Here
307
308
309
310
311
312
313
314
315
316
317
          //log.debug("Recipient has {} connections", rcons.size());
          Object[] sendobj = new Object[] { client.getId(), "This is a message from " + name };
          for (IConnection rcon : rcons) {
            if (rcon instanceof IServiceCapableConnection) {
              serviceCapCon = (IServiceCapableConnection) rcon;
              serviceCapCon.invoke("privMessage", sendobj);
              break;
            } else {
              log.info("Connection is not service capable");
            }
          }
View Full Code Here
337
338
339
340
341
342
343
344
345
346
347
          //log.debug("Recipient has {} connections", rcons.size());
          Object[] sendobj = new Object[] { client.getId(), "This is a message from " + name };
          for (IConnection rcon : rcons) {
            if (rcon instanceof IServiceCapableConnection) {
              serviceCapCon = (IServiceCapableConnection) rcon;
              serviceCapCon.invoke("privMessage", sendobj);
              break;
            } else {
              log.info("Connection is not service capable");
            }
          }
View Full Code Here
193
194
195
196
197
198
199
200
201
202
203
      log.debug("### Client connected to OpenMeetings, register Client StreamId: "
          + streamId + " scope " + conn.getScope().getName()+ " isAVClient "+isAVClient);
      log.debug("params "+params);

      // Set StreamId in Client
      service.invoke("setId", new Object[] { streamId }, this);

      String swfURL = "";
      if (conn.getConnectParams().get("swfUrl") != null) {
        swfURL = conn.getConnectParams().get("swfUrl").toString();
      }
View Full Code Here
784
785
786
787
788
789
790
791
792
793
794
              }
             
              log.debug("RCL SEND is equal newStream SEND "+rcl.getPublicSID()+" || "+rcl.getUserport());
               
              IServiceCapableConnection iStream = (IServiceCapableConnection) conn;
              iStream.invoke("newStream",
                  new Object[] { clientObjectSendToSync },
                  this);

            }
          }
View Full Code Here
971
972
973
974
975
976
977
978
979
980
981
                        + rcl);
                    // conn.ping();
                    IServiceCapableConnection iStream = (IServiceCapableConnection) conn;
                    // log.info("IServiceCapableConnection ID "
                    // + iStream.getClient().getId());
                    iStream.invoke(clientFunction,
                        new Object[] { rc }, this);
                  }

                  log.debug("sending notification to " + conn
                      + " ID: ");
View Full Code Here
1086
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
                  // Check if the Client is in the same room
                  // and same domain
                  IServiceCapableConnection iStream = (IServiceCapableConnection) conn;
                  // log.info("IServiceCapableConnection ID "
                  // + iStream.getClient().getId());
                  iStream.invoke("newRed5ScreenCursor",
                      new Object[] { cursor }, this);
                  // log.debug("send Notification to");
                }
              }
            }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
              return;
            }
           
            state.set(State.values.framegrabbusy.name(), true);
            IServiceCapableConnection sc = (IServiceCapableConnection) grabber;
            sc.invoke("framegrabMedium", new Object[] {});
           
            while (state.getBoolean(State.values.framegrabbusy)) {
              int n = 0;
              Thread.sleep(5);
              n++;
View Full Code Here
336
337
338
339
340
341
342
343
344
345
346
          authtoken =  null;
        }
        str += " someonealreadydriving " + state.get(State.values.driver.name());

        // this has to be last to above variables are already set in java script
        sc.invoke("message", new Object[] { null, "green", "multiple", str });
        str = state.get(State.values.pendinguserconnected) + " pending connection from: "
            + pendingplayer.getRemoteAddress();
       
        Util.log("playersignin(): " + str);
        messageGrabber(str, null);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.