code: @Override
      public void connect(String server, int port, Map<String, Object> connectionParams, IPendingServiceCallback connectCallback, Object[] connectCallArguments) {
          log.debug("connect server: {} port {} connect - params: {} callback: {} args: {}", new Object[] { server, port, connectionParams, connectCallback, Arrays.toString(connectCallArguments) });
          log.info("{}://{}:{}/{}", new Object[] { protocol, server, port, connectionParams.get("app") });
          this.connectionParams = connectionParams;
          this.connectArguments = connectCallArguments;
          if (!connectionParams.containsKey("objectEncoding")) {
              connectionParams.put("objectEncoding", 0);
          }
          this.connectCallback = connectCallback;
          startConnector(server, port);
      }
docs: Connect RTMP client to server's application via given port
  
  @param server
  Server
  @param port
  Connection port
  @param connectionParams
  Connection parameters
  @param connectCallback
  Connection callback
  @param connectCallArguments
  Arguments for 'connect' call