Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for connect0 (0.28 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/net/protocol/gcs/HandlerTest.java

            try {
                conn.connect();
                fail("Should throw IOException when project ID is not set");
            } catch (IOException e) {
                assertTrue(e.getMessage().contains("GCS_PROJECT_ID is blank"));
            }
        }
    
        /**
         * Test thread-safety of connect() method.
         * Multiple threads should be able to call connect() concurrently without issues.
         */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/gcs/Handler.java

             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
                if (connected) {
                    return;
                }
                final String projectId = System.getenv("GCS_PROJECT_ID");
                final String endpoint = System.getenv("GCS_ENDPOINT");
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/s3/Handler.java

             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
                if (connected) {
                    return;
                }
                final String endpoint = System.getenv().get("S3_ENDPOINT");
                final String accessKey = System.getenv().get("S3_ACCESS_KEY");
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 07:57:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

        /**
         * Checks if the client is connected to OpenSearch.
         *
         * @return true if connected, false otherwise.
         */
        public boolean connected() {
            return connected;
        }
    
        /**
         * Connects to the OpenSearch cluster.
         * Creates a new client and waits for cluster health to be yellow or better.
         */
        public void connect() {
            destroy();
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 02:01:26 UTC 2025
    - 26.2K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/net/protocol/storage/HandlerTest.java

            try {
                conn.connect();
                fail("Should throw IOException when endpoint is not set");
            } catch (IOException e) {
                assertTrue(e.getMessage().contains("endpoint is blank"));
            }
        }
    
        /**
         * Test thread-safety of connect() method.
         * Multiple threads should be able to call connect() concurrently without issues.
         */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/sso/oic/OpenIdConnectAuthenticator.java

        protected static final String OIC_REDIRECT_URL = "oic.redirect.url";
    
        /** Configuration key for OpenID Connect token server URL. */
        protected static final String OIC_TOKEN_SERVER_URL = "oic.token.server.url";
    
        /** Configuration key for OpenID Connect client secret. */
        protected static final String OIC_CLIENT_SECRET = "oic.client.secret";
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sun Dec 14 01:18:25 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/curl/CurlRequest.java

            return this;
        }
    
        /**
         * Connects to the URL and executes the request.
         *
         * @param actionListener the action listener for handling the response
         * @param exceptionListener the exception listener for handling exceptions
         */
        public void connect(final Consumer<HttpURLConnection> actionListener, final Consumer<Exception> exceptionListener) {
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Mon Nov 24 03:10:07 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

         * The active maximum port.
         */
        protected int activeMaxPort;
    
        /**
         * Whether to autodetect encoding.
         */
        protected boolean autodetectEncoding;
    
        /**
         * The connect timeout.
         */
        protected int connectTimeout;
    
        /**
         * The data timeout.
         */
        protected int dataTimeout;
    
        /**
         * The control encoding.
         */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 40K bytes
    - Viewed (0)
  9. CLAUDE.md

    mvn deploy
    ```
    
    ## Architecture
    
    ### Core Components
    
    - **`org.codelibs.curl.Curl`**: Static entry point providing factory methods for all HTTP methods (GET, POST, PUT, DELETE, HEAD, OPTIONS, CONNECT, TRACE)
    - **`org.codelibs.curl.CurlRequest`**: Fluent request builder supporting parameters, headers, body content, SSL config, proxies, timeouts, and caching
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Mon Nov 24 03:10:07 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java

    import com.nimbusds.jwt.JWTParser;
    import com.nimbusds.oauth2.sdk.AuthorizationCode;
    import com.nimbusds.openid.connect.sdk.AuthenticationErrorResponse;
    import com.nimbusds.openid.connect.sdk.AuthenticationResponse;
    import com.nimbusds.openid.connect.sdk.AuthenticationResponseParser;
    import com.nimbusds.openid.connect.sdk.AuthenticationSuccessResponse;
    
    import jakarta.annotation.PostConstruct;
    import jakarta.servlet.http.HttpServletRequest;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 13 02:21:17 UTC 2025
    - 56.7K bytes
    - Viewed (0)
Back to top