code: @Override
      public RTMPConnection createConnection(Class<?> connCls) {
          RTMPConnection conn = null;
          if (RTMPConnection.class.isAssignableFrom(connCls)) {
              try {
                  // create connection
                  conn = createConnectionInstance(connCls);
                  // add to local map
                  connMap.put(conn.getSessionId(), conn);
                  log.trace("Connections: {}", conns.incrementAndGet());
                  log.trace("Connection created: {}", conn);
              } catch (Exception ex) {
                  log.warn("Exception creating connection", ex);
              }
          }
          return conn;
      }
docs: {@inheritDoc}