Examples of com.google.common.eventbus.EventBus.register()

Class com.google.common.eventbus.EventBus

Examples of com.google.common.eventbus.EventBus.register()

com.google.common.eventbus.EventBus.register()
Registers all handler methods on {@code object} to receive events.Handler methods are selected and classified using this EventBus's {@link HandlerFindingStrategy}; the default strategy is the {@link AnnotatedHandlerFinder}. @param object object whose handler methods should be registered. @throws IllegalArgumentException if no public subscribe methods are found on object


        // given
        EventBus eventBus = new EventBus("test");


        DeadEventListener deadEventListener = new DeadEventListener();
        eventBus.register(deadEventListener);


        // when
        eventBus.post(new OurTestEvent(200));


        assertThat(deadEventListener.isNotDelivered()).isTrue();

View Full Code Here


        // given
        EventBus eventBus = new EventBus("test");
        IntegerListener integerListener = new IntegerListener();
        NumberListener numberListener = new NumberListener();
        eventBus.register(integerListener);
        eventBus.register(numberListener);


        // when
        eventBus.post(new Integer(100));

View Full Code Here

        // given
        EventBus eventBus = new EventBus("test");
        IntegerListener integerListener = new IntegerListener();
        NumberListener numberListener = new NumberListener();
        eventBus.register(integerListener);
        eventBus.register(numberListener);


        // when
        eventBus.post(new Integer(100));


        // then

View Full Code Here


        // given
        EventBus eventBus = new EventBus("test");
        EventListener listener = new EventListener();


        eventBus.register(listener);


        // when
        eventBus.post(new OurTestEvent(200));


        // then

View Full Code Here

      replay(mockFuture);
      replay(schedulerMock);


      CoutingEventHandler handler = new CoutingEventHandler();
      EventBus eventBus = new EventBus();
      eventBus.register(handler);


      AsyncMonitor<Object> monitor = mockMonitor(schedulerMock, new Object(), mockFunction(MonitorStatus.DONE),
            eventBus);


      assertNull(monitor.getFuture());

View Full Code Here

      replay(mockFuture);
      replay(schedulerMock);


      CoutingEventHandler handler = new CoutingEventHandler();
      EventBus eventBus = new EventBus();
      eventBus.register(handler);


      AsyncMonitor<Object> monitor = mockMonitor(schedulerMock, new Object(), mockFunction(MonitorStatus.FAILED),
            eventBus);


      assertNull(monitor.getFuture());

View Full Code Here

      replay(mockFuture);
      replay(schedulerMock);


      CoutingEventHandler handler = new CoutingEventHandler();
      EventBus eventBus = new EventBus();
      eventBus.register(handler);


      AsyncMonitor<Object> monitor = mockMonitor(schedulerMock, new Object(), mockFunction(MonitorStatus.CONTINUE),
            eventBus);


      assertNull(monitor.getFuture());

View Full Code Here

      replay(mockFuture);
      replay(schedulerMock);


      CoutingEventHandler handler = new CoutingEventHandler();
      EventBus eventBus = new EventBus();
      eventBus.register(handler);


      AsyncMonitor<Object> monitor = mockMonitor(schedulerMock, new Object(), mockFunction(MonitorStatus.CONTINUE),
            eventBus);


      assertNull(monitor.getFuture());

View Full Code Here

    long start = System.currentTimeMillis();    
    final List<String> testClassNames = processTestResources();


    final EventBus aggregatedBus = new EventBus("aggregated");
    final TestsSummaryEventListener summaryListener = new TestsSummaryEventListener();
    aggregatedBus.register(summaryListener);
    
    for (Object o : listeners) {
      if (o instanceof ProjectComponent) {
        ((ProjectComponent) o).setProject(getProject());
      }

View Full Code Here

        ((ProjectComponent) o).setProject(getProject());
      }
      if (o instanceof AggregatedEventListener) {
        ((AggregatedEventListener) o).setOuter(this);
      }
      aggregatedBus.register(o);
    }


    if (testClassNames.isEmpty()) {
      aggregatedBus.post(new AggregatedQuitEvent());
    } else {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.