- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 2,683 for EVENT (0.06 sec)
-
maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/util/ConsoleTransferListener.java
} @Override public void transferFailed(TransferEvent event) { transferCompleted(event); println( "transferFailed", event.getException().getClass() + ": " + event.getException().getMessage()); } private void transferCompleted(TransferEvent event) { downloads.remove(event.getResource()); StringBuilder buffer = new StringBuilder(64);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Dec 26 15:12:32 UTC 2022 - 5.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/AbstractExecutionListener.java
// default does nothing } public void projectSucceeded(ExecutionEvent event) { // default does nothing } public void projectFailed(ExecutionEvent event) { // default does nothing } public void forkStarted(ExecutionEvent event) { // default does nothing } public void forkSucceeded(ExecutionEvent event) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 2.6K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/progress/DefaultProgressLoggerFactoryTest.groovy
1 * progressListener.started(!null) >> { ProgressStartEvent event -> assert event.description == "parent" assert event.parentProgressOperationId == null assert event.progressOperationId != null parentId = event.progressOperationId } 1 * progressListener.started(!null) >> { ProgressStartEvent event -> assert event.description == "child"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 10.6K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/AbstractMavenTransferListener.java
} @Override public void transferSucceeded(TransferEvent event) { String action = (event.getRequestType() == TransferEvent.RequestType.PUT ? "Uploaded" : "Downloaded"); String direction = event.getRequestType() == TransferEvent.RequestType.PUT ? "to" : "from"; TransferResource resource = event.getResource(); long contentLength = event.getTransferredBytes(); FileSizeFormat format = new FileSizeFormat();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 21:48:41 UTC 2024 - 4.1K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
ongoing.remove(new TransferResourceIdentifier(event.getResource())); put(event, ongoing.isEmpty()); } private static class Exchange { private final TransferEvent event; private Exchange(TransferEvent event) { this.event = event; } public void process(Consumer<TransferEvent> consumer) { consumer.accept(event); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/aether/LoggingRepositoryListener.java
public void artifactInstalling(RepositoryEvent event) { logger.info("Installing {} to {}", event.getArtifact().getFile(), event.getFile()); } @Override public void metadataInstalling(RepositoryEvent event) { logger.debug("Installing {} to {}", event.getMetadata(), event.getFile()); } @Override public void metadataResolved(RepositoryEvent event) { Exception e = event.getException();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Jun 06 19:10:58 UTC 2024 - 3.4K bytes - Viewed (0) -
internal/event/target/mqtt.go
} return true, nil } // send - sends an event to the mqtt. func (target *MQTTTarget) send(eventData event.Event) error { objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err } key := eventData.S3.Bucket.Name + "/" + objectName data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}}) if err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
} }; @Override void dispatch(Object event, Iterator<Subscriber> subscribers) { checkNotNull(event); checkNotNull(subscribers); // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get Queue<Event> queueForThread = requireNonNull(queue.get()); queueForThread.offer(new Event(event, subscribers)); if (!dispatching.get()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Dispatcher.java
} }; @Override void dispatch(Object event, Iterator<Subscriber> subscribers) { checkNotNull(event); checkNotNull(subscribers); // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get Queue<Event> queueForThread = requireNonNull(queue.get()); queueForThread.offer(new Event(event, subscribers)); if (!dispatching.get()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-elasticsearch-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15K bytes - Viewed (0)