- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 272 for eventbus (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)