- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 242 for Event (0.01 sec)
-
impl/maven-core/src/test/java/org/apache/maven/lifecycle/LifecycleExecutorTest.java
assertNotNull(event.getSession()); assertNotNull(event.getProject()); assertNotNull(event.getExecution()); assertNotNull(event.getMojo()); assertNull(event.getCause()); log.add("beforeMojoExecution " + event.getProject().getArtifactId() + ":"
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Sep 17 10:01:14 UTC 2025 - 22.9K bytes - Viewed (0) -
internal/event/target/mysql.go
if target.args.Format == event.NamespaceFormat { objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err } key := eventData.S3.Bucket.Name + "/" + objectName if eventData.EventName == event.ObjectRemovedDelete { _, err = target.deleteStmt.Exec(key) } else { var data []byte if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 11.6K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/event/ExecutionEventLogger.java
@Override public void forkedProjectStarted(ExecutionEvent event) { if (logger.isInfoEnabled() && event.getMojoExecution().getForkedExecutions().size() > 1) { init(); logger.info(""); infoLine('>'); infoMain("Forking " + event.getProject().getName() + " " + event.getProject().getVersion()); infoLine('>'); }Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Dec 13 15:40:45 UTC 2024 - 17.5K bytes - Viewed (0) -
compat/maven-embedder/src/test/java/org/apache/maven/cli/event/ExecutionEventLoggerTest.java
when(session.getTopDirectory()).thenReturn(basedir.toPath()); when(event.getSession()).thenReturn(session); // execute executionEventLogger.projectStarted(event); // verify InOrder inOrder = inOrder(logger); inOrder.verify(logger).info("");
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Sun Dec 01 19:41:22 UTC 2024 - 12.3K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/aether/ReverseTreeRepositoryListener.java
@Override public void artifactResolved(RepositoryEvent event) { requireNonNull(event, "event cannot be null"); if (!isLocalRepositoryArtifactOrMissing(event.getSession(), event.getArtifact())) { return; } RequestTrace trace = event.getTrace(); CollectStepData collectStepTrace = null; ArtifactRequest artifactRequest = null;Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jan 29 08:17:07 UTC 2025 - 10.1K bytes - Viewed (0) -
internal/event/target/nats.go
func NewNATSTarget(id string, args NATSArgs, loggerOnce logger.LogOnce) (*NATSTarget, error) { var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-nats-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Apr 27 04:30:57 UTC 2025 - 13.5K bytes - Viewed (0) -
internal/event/config_test.go
dataCase1 := []byte(` <QueueConfiguration> <Id>1</Id> <Filter></Filter> <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue> <Event>s3:ObjectAccessed:*</Event> <Event>s3:ObjectCreated:*</Event> <Event>s3:ObjectRemoved:*</Event> </QueueConfiguration>`) dataCase2 := []byte(` <QueueConfiguration> <Id>1</Id> <Filter> <S3Key> <FilterRule>
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 28.9K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/event/ExecutionEventLogger.java
@Override public void forkedProjectStarted(ExecutionEvent event) { if (logger.isInfoEnabled() && event.getMojoExecution().getForkedExecutions().size() > 1) { init(); logger.info(""); infoLine('>'); infoMain("Forking " + event.getProject().getName() + " " + event.getProject().getVersion()); infoLine('>'); }Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Nov 08 08:49:11 UTC 2024 - 17.2K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15K bytes - Viewed (0) -
internal/event/target/kafka.go
initOnce once.Init id event.TargetID args KafkaArgs client sarama.Client producer sarama.SyncProducer config *sarama.Config store store.Store[event.Event] batch *store.Batch[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *KafkaTarget) ID() event.TargetID { return target.id }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0)