Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 272 for eventbus (0.09 sec)

  1. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/Mojo.java

         */
        void execute() throws MojoExecutionException, MojoFailureException;
    
        /**
         * Inject a standard <code>Maven</code> logging mechanism to allow this <code>Mojo</code> to communicate events
         * and feedback to the user.
         *
         * @param log a new logger
         *
         * @deprecated Use SLF4J directly
         */
        @Deprecated
        void setLog(Log log);
    
        /**
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. impl/maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyRepositoryListener.java

    package org.apache.maven.eventspy.internal;
    
    import org.eclipse.aether.AbstractRepositoryListener;
    import org.eclipse.aether.RepositoryEvent;
    import org.eclipse.aether.RepositoryListener;
    
    /**
     * Forwards repository events to EventSpies.
     * @since 3.0.2
     */
    class EventSpyRepositoryListener extends AbstractRepositoryListener {
        private final EventSpyDispatcher dispatcher;
    
        private final RepositoryListener delegate;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolver.java

    import org.apache.maven.artifact.metadata.ArtifactMetadataSource;
    import org.apache.maven.artifact.repository.ArtifactRepository;
    import org.apache.maven.artifact.resolver.filter.ArtifactFilter;
    import org.apache.maven.wagon.events.TransferListener;
    
    /**
     */
    // Just hide the one method we want behind the RepositorySystem interface.
    @Deprecated
    public interface ArtifactResolver {
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  4. docs/en/mkdocs.yml

        - advanced/middleware.md
        - advanced/sub-applications.md
        - advanced/behind-a-proxy.md
        - advanced/templates.md
        - advanced/websockets.md
        - advanced/events.md
        - advanced/testing-websockets.md
        - advanced/testing-events.md
        - advanced/testing-dependencies.md
        - advanced/async-tests.md
        - advanced/settings.md
        - advanced/openapi-callbacks.md
        - advanced/openapi-webhooks.md
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 22 20:28:02 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  5. docs/metrics/prometheus/list.md

    | `minio_notify_events_errors_total`             | Events that were failed to be sent to the targets (deprecated, please use `minio_notify_target_failed_events` instead)                      |
    | `minio_notify_events_sent_total`               | Total number of events sent to the targets (deprecated, please use `minio_notify_target_total_events` instead)                              |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:48:51 UTC 2024
    - 43.3K bytes
    - Viewed (0)
  6. internal/event/target/redis.go

    	if pingErr != nil {
    		if xnet.IsConnRefusedErr(pingErr) {
    			return false, store.ErrNotConnected
    		}
    		return false, pingErr
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the redis connection is active.
    func (target *RedisTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ResolutionListener.java

     */
    package org.apache.maven.artifact.resolver;
    
    import org.apache.maven.artifact.Artifact;
    import org.apache.maven.artifact.versioning.VersionRange;
    
    /**
     * Listens to the resolution process and handles events.
     *
     */
    @Deprecated
    public interface ResolutionListener {
        String ROLE = ResolutionListener.class.getName();
    
        int TEST_ARTIFACT = 1;
    
        int PROCESS_CHILDREN = 2;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  8. compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java

            try {
                endLatch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
            // despite all are back, we need to make sure all the events are processed (are async)
            // this one should block until all processed
            listener.transferSucceeded(new TransferEvent.Builder(session, resource)
                    .setType(TransferEvent.EventType.SUCCEEDED)
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. internal/event/target/mysql.go

    	if err := target.db.Ping(); err != nil {
    		if IsConnErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the SQL connection is active.
    func (target *MySQLTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  10. internal/event/target/postgresql.go

    	if err := target.db.Ping(); err != nil {
    		if IsConnErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the PostgreSQL connection is active.
    func (target *PostgreSQLTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top