Examples of registerHandler()

Examples of edu.stanford.bmir.protege.web.shared.event.EventBusManager.registerHandler()

473
474
475
476
477
478
479
480
481
482
483
        handlerRegistrations.add(reg);
    }

    public <T> void addApplicationEventHandler(Event.Type<T> type, T handler) {
        EventBusManager manager = EventBusManager.getManager();
        HandlerRegistration reg = manager.registerHandler(checkNotNull(type), checkNotNull(handler));
        handlerRegistrations.add(reg);
    }


    public boolean isEventForThisProject(Event<?> event) {
View Full Code Here

Examples of io.crate.rest.CrateRestMainAction.registerHandler()

115
116
117
118
119
120
121
122
123
124
125
            encounter.register(new InjectionListener<I>() {
                @Override
                public void afterInjection(I injectee) {
                    try {
                        CrateRestMainAction crateRestMainAction = instanceFuture.get(10, TimeUnit.SECONDS);
                        crateRestMainAction.registerHandler();
                    } catch (Exception e) {
                        logger.error("Could not register CrateRestMainAction handler", e);
                    }
                }
            });
View Full Code Here

Examples of io.vertx.rxcore.java.eventbus.RxEventBus.registerHandler()

46
47
48
49
50
51
52
53
54
55
56
public class EventBusIntegrationTest extends TestVerticle {

  @Test
  public void testSimpleSubscribeReply() {
    RxEventBus rxEventBus = new RxEventBus(vertx.eventBus());
    rxEventBus.<String>registerHandler("foo").subscribe(new Action1<RxMessage<String>>() {
      @Override
      public void call(RxMessage<String> message) {
        message.reply("pong!");
      }
    });
View Full Code Here

Examples of io.vertx.rxcore.java.eventbus.RxEventBus.registerHandler()

71
72
73
74
75
76
77
78
79
80
81
  public void testSimpleSerial() {
    final RxEventBus rxEventBus = new RxEventBus(vertx.eventBus());
    final AtomicInteger totalReqs = new AtomicInteger(3);
    final AtomicInteger activeReqs = new AtomicInteger(0);
   
    rxEventBus.<String>registerHandler("foo").subscribe(new Action1<RxMessage<String>>() {
      @Override
      public void call(RxMessage<String> message) {
        System.out.println("serial-foo["+message.body()+"]");
        message.reply("pong!");
        activeReqs.incrementAndGet();
View Full Code Here

Examples of io.vertx.rxcore.java.eventbus.RxEventBus.registerHandler()

103
104
105
106
107
108
109
110
111
112
113
  @Test
  // Send some messages in series where next message sent is function of reply from previous message
  public void testSerial() {
    final RxEventBus rxEventBus = new RxEventBus(vertx.eventBus());

    rxEventBus.<String>registerHandler("foo").subscribe(new Action1<RxMessage<String>>() {
      @Override
      public void call(RxMessage<String> message) {
        message.reply(message.body());
      }
    });
View Full Code Here

Examples of io.vertx.rxcore.java.eventbus.RxEventBus.registerHandler()

133
134
135
136
137
138
139
140
141
142
143
  // Send some messages in parallel and wait for all replies before doing something
  public void testGather() {

    final RxEventBus rxEventBus = new RxEventBus(vertx.eventBus());

    rxEventBus.<String>registerHandler("foo").subscribe(new Action1<RxMessage<String>>() {
      @Override
      public void call(RxMessage<String> msg) {
        msg.reply("pong"+msg.body());
      }
    });
View Full Code Here

Examples of io.vertx.rxcore.java.eventbus.RxEventBus.registerHandler()

153
154
155
156
157
158
159
160
161
162
163
  @Test
  // Send some messages in parallel and return result of concatenating all the messages
  public void testConcatResults() {
    final RxEventBus rxEventBus = new RxEventBus(vertx.eventBus());

    rxEventBus.<String>registerHandler("foo").subscribe(new Action1<RxMessage<String>>() {
      @Override
      public void call(RxMessage<String> msg) {
        msg.reply("pong"+msg.body());
      }
    });
View Full Code Here

Examples of io.vertx.rxcore.java.eventbus.RxEventBus.registerHandler()

178
179
180
181
182
183
184
185
186
187
188
  @Test
  public void testSimpleRegisterHandler() {
    final RxEventBus rxEventBus = new RxEventBus(vertx.eventBus());

    Observable<RxMessage<String>> obs = rxEventBus.registerHandler("foo");

    assertMessageThenComplete(obs.take(1),"hello");

    // Send using core EventBus
    vertx.eventBus().send("foo", "hello");
View Full Code Here

Examples of io.vertx.rxcore.java.eventbus.RxEventBus.registerHandler()

190
191
192
193
194
195
196
197
198
199
200
  @Test
  public void testReplyToReply() {
    final RxEventBus rxEventBus = new RxEventBus(vertx.eventBus());

    Observable<RxMessage<String>> obsReply1 = rxEventBus.registerHandler("foo");

    Observable<RxMessage<String>> obsReply2 = obsReply1.flatMap(new Func1<RxMessage<String>, Observable<RxMessage<String>>>() {
      @Override
      public Observable<RxMessage<String>> call(RxMessage<String> stringRxMessage) {
        // Reply to the message
View Full Code Here

Examples of logisticspipes.modules.abstractmodules.LogisticsModule.registerHandler()

303
304
305
306
307
308
309
310
311
312
313
        if(currentModule != null) {
          if (module.getILogisticsModuleClass().equals(currentModule.getClass())) return currentModule;
        }
        LogisticsModule newmodule = module.getILogisticsModule();
        if(newmodule == null) return null;
        newmodule.registerHandler(world, service);
        return newmodule;
      }
    }
    return null;
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.