Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 295 for eventbus (0.15 sec)

  1. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DebugResolutionListener.java

    import java.util.Objects;
    import java.util.Set;
    
    import org.apache.maven.artifact.Artifact;
    import org.apache.maven.artifact.versioning.VersionRange;
    import org.codehaus.plexus.logging.Logger;
    
    /**
     * Send resolution events to the debug log.
     *
     */
    @Deprecated
    public class DebugResolutionListener implements ResolutionListener, ResolutionListenerForDepMgmt {
        private Logger logger;
    
        private String indent = "";
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. docs/en/docs/advanced/openapi-webhooks.md

    ## Webhooks steps
    
    The process normally is that **you define** in your code what is the message that you will send, the **body of the request**.
    
    You also define in some way at which **moments** your app will send those requests or events.
    
    And **your users** define in some way (for example in a web dashboard somewhere) the **URL** where your app should send those requests.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:38:23 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. internal/pubsub/pubsub.go

    	sync.RWMutex
    }
    
    // Publish message to the subscribers.
    // Note that publish is always non-blocking send so that we don't block on slow receivers.
    // Hence receivers should use buffered channel so as not to miss the published events.
    func (ps *PubSub[T, M]) Publish(item T) {
    	ps.RLock()
    	defer ps.RUnlock()
    	for _, sub := range ps.subs {
    		if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) {
    			select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. docs/bucket/lifecycle/DESIGN.md

    ### Expiry or removal events
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  5. .github/workflows/codeql.yml

        runs-on: ${{ (matrix.language == 'swift' && 'macos-latest') || 'ubuntu-latest' }}
        timeout-minutes: ${{ (matrix.language == 'swift' && 120) || 360 }}
        permissions:
          # required for all workflows
          security-events: write
    
          # required to fetch internal or private CodeQL packs
          packages: read
    
          # only required for workflows in private repositories
          actions: read
          contents: read
    
        strategy:
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Aug 14 23:51:19 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt

    import java.util.ArrayDeque
    import java.util.Deque
    import okio.Buffer
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Test
    
    class ServerSentEventIteratorTest {
      /** Either [Event] or [Long] items for events and retry changes, respectively.  */
      private val callbacks: Deque<Any> = ArrayDeque()
    
      @AfterEach
      fun after() {
        assertThat(callbacks).isEmpty()
      }
    
      @Test
      fun multiline() {
        consumeEvents(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  7. cmd/iam-etcd-store.go

    		err = errNoSuchGroup
    	}
    	return err
    }
    
    func (ies *IAMEtcdStore) watch(ctx context.Context, keyPath string) <-chan iamWatchEvent {
    	ch := make(chan iamWatchEvent)
    
    	// go routine to read events from the etcd watch channel and send them
    	// down `ch`
    	go func() {
    		for {
    		outerLoop:
    			watchCh := ies.client.Watch(ctx,
    				keyPath, etcd.WithPrefix(), etcd.WithKeysOnly())
    
    			for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.29.md

    - `kubectl` will not print events if `--show-events=false` argument is passed to
      describe PVC subcommand. ([#120380](https://github.com/kubernetes/kubernetes/pull/120380), [@MaGaroo](https://github.com/MaGaroo))
    - `scheduler`: Fixed missing field `apiVersion` from events reported by the taint
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 04:37:31 UTC 2024
    - 375.1K bytes
    - Viewed (1)
  9. internal/event/target/elasticsearch.go

    	defer cancel()
    
    	err := target.checkAndInitClient(ctx)
    	if err != nil {
    		return false, err
    	}
    
    	return target.client.ping(ctx, target.args)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will be replayed when the elasticsearch connection is active.
    func (target *ElasticsearchTarget) 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
    - 15K bytes
    - Viewed (0)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

     * on single thread, keeping the listener logic simple. This listener also blocks on last transfer event to allow
     * output to perform possible cleanup. It spawns a daemon thread to consume queued events that may fall in even
     * concurrently.
     *
     * @since 4.0.0
     */
    public final class SimplexTransferListener extends AbstractTransferListener {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top