Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 65 for subscriber (0.1 sec)

  1. guava/src/com/google/common/eventbus/DeadEvent.java

    import static com.google.common.base.Preconditions.checkNotNull;
    
    import com.google.common.base.MoreObjects;
    
    /**
     * Wraps an event that was posted, but which had no subscribers and thus could not be delivered.
     *
     * <p>Registering a DeadEvent subscriber is useful for debugging or logging, as it can detect
     * misconfigurations in a system's event distribution.
     *
     * @author Cliff Biffle
     * @since 10.0
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub_test.go

    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(Mask(2)); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(Mask(1|2)); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(MaskAll); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. docs/bucket/notifications/README.md

          if c.NatsConn() != nil {
           c.NatsConn().Close()
          }
          _ = c.Close()
         }))
         if stanConnection != nil {
          subscribe()
         }
    
        }
       }
    
      }()
     }))
    
     // Subscribe to subject
     subscribe()
    
     // Keep the connection alive
     runtime.Goexit()
    }
    
    ```
    
    ```
    go run nats.go
    2017/07/07 11:47:40 Connected
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  4. cmd/consolelogger.go

    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error {
    	// Enable console logging for remote client.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-parent.xml

      <url>http://www.apache.org/</url>
    
      <mailingLists>
        <mailingList>
          <name>parent</name>
          <post>******@****.***</post>
          <subscribe>subscribe@mailing.list.com</subscribe>
          <unsubscribe>******@****.***</unsubscribe>
        </mailingList>
      </mailingLists>
    
      <build>
        <plugins>
          <plugin>
            <groupId>inheritance.configuration</groupId>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/eventbus/outside/AnnotatedNotAbstractInSuperclassTest.java

        @Subscribe
        public void notOverriddenInSubclass(Object o) {
          notOverriddenInSubclassEvents.add(o);
        }
    
        @Subscribe
        public void overriddenNotAnnotatedInSubclass(Object o) {
          overriddenNotAnnotatedInSubclassEvents.add(o);
        }
    
        @Subscribe
        public void overriddenAndAnnotatedInSubclass(Object o) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 08 21:35:40 UTC 2022
    - 4.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/eventbus/outside/DeepInterfaceTest.java

    import com.google.common.eventbus.Subscribe;
    import com.google.common.eventbus.outside.DeepInterfaceTest.SubscriberClass;
    import java.util.List;
    
    public class DeepInterfaceTest extends AbstractEventBusTest<SubscriberClass> {
      interface Interface1 {
        @Subscribe
        void annotatedIn1(Object o);
    
        @Subscribe
        void annotatedIn1And2(Object o);
    
        @Subscribe
        void annotatedIn1And2AndClass(Object o);
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 08 21:35:40 UTC 2022
    - 4.2K bytes
    - Viewed (0)
  8. compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-child.xml

      <mailingLists>
        <!--mailingList> MNG-3124: no way to add a list to parent content, only full override
          <name>child</name>
          <post>******@****.***</post>
          <subscribe>subscribe@mailing.list.com</subscribe>
          <unsubscribe>******@****.***</unsubscribe>
        </mailingList-->
      </mailingLists>
    
      <build>
        <plugins>
          <plugin>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/eventbus/outside/AnnotatedAndAbstractInSuperclassTest.java

    import com.google.common.eventbus.Subscribe;
    import com.google.common.eventbus.outside.AnnotatedAndAbstractInSuperclassTest.SubClass;
    import java.util.List;
    
    public class AnnotatedAndAbstractInSuperclassTest extends AbstractEventBusTest<SubClass> {
      abstract static class SuperClass {
        @Subscribe
        public abstract void overriddenAndAnnotatedInSubclass(Object o);
    
        @Subscribe
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 08 21:35:40 UTC 2022
    - 2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/eventbus/outside/AnnotatedAndAbstractInSuperclassTest.java

    import com.google.common.eventbus.Subscribe;
    import com.google.common.eventbus.outside.AnnotatedAndAbstractInSuperclassTest.SubClass;
    import java.util.List;
    
    public class AnnotatedAndAbstractInSuperclassTest extends AbstractEventBusTest<SubClass> {
      abstract static class SuperClass {
        @Subscribe
        public abstract void overriddenAndAnnotatedInSubclass(Object o);
    
        @Subscribe
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 08 21:35:40 UTC 2022
    - 2K bytes
    - Viewed (0)
Back to top