Examples of register()

Examples of org.rioproject.eventcollector.api.EventCollector.register()

59
60
61
62
63
64
65
66
67
68
69
        } catch(Error e) {
            System.out.println("Factory already defined, move along");
        }
        EventCollector eventCollector = (EventCollector)testManager.waitForService(EventCollector.class);
        Assert.assertNotNull(eventCollector);
        EventCollectorRegistration registration1 = eventCollector.register(Lease.ANY);
        EventCollectorRegistration registration2 = eventCollector.register(Lease.ANY);

        BasicEventListener listener1 = new BasicEventListener();
        RemoteEventListener eventListener = listener1.export();
        registration1.enableDelivery(eventListener);
View Full Code Here

Examples of org.rioproject.impl.event.BasicEventConsumer.register()

118
119
120
121
122
123
124
125
126
127
128
        } catch (Exception e) {
            e.printStackTrace();
        }
        Assert.assertNotNull(bec);
        for(ServiceItem item : items)
            bec.register(item);

        Throwable thrown = null;
        try {
            simple.hello(null);
            Thread.sleep(500);
View Full Code Here

Examples of org.rioproject.impl.event.DynamicEventConsumer.register()

52
53
54
55
56
57
58
59
60
61
62
            e.printStackTrace();
        }
        Assert.assertNull(t);
        Assert.assertNotNull(eventConsumer);
        Listener listener = new Listener();
        eventConsumer.register(listener);
        int waitCount = 0;
        while(!listener.upperBreachNotification() && waitCount<10) {
            try {
                service.increment();
                Thread.sleep(500);
View Full Code Here

Examples of org.rioproject.impl.servicebean.ServiceBeanActivation.LifeCycleManager.register()

162
163
164
165
166
167
168
169
170
171
172
                                                                BannerProvider.class,
                                                                new BannerProviderImpl());
        logger.info(bannerProvider.getBanner(context.getServiceElement().getName()));
        start(context);
        LifeCycleManager lMgr = (LifeCycleManager)context.getServiceBeanManager().getDiscardManager();
        lMgr.register(getServiceProxy(), context);
    }

    /**
     * Override destroy to ensure that all OpStringManagers are shutdown as well
     */
 
View Full Code Here

Examples of org.seattlegamer.spacegame.core.Bus.register()

70
71
72
73
74
75
76
77
78
79
80
    Bus bus = bus();
    Collection<State> states = new LinkedList<State>();
    states.add(gameState());
    states.add(menuState());
    StateManager stateManager = new StateManager(states);
    bus.register(stateManager, null);
    bus.broadcast(new StateChange(MenuState.class));
    return stateManager;

  }
 
View Full Code Here

Examples of org.seattlegamer.spacegame.core.BusImpl.register()

20
21
22
23
24
25
26
27
28
29
30
    UUID entityId = UUID.randomUUID();
   
    Foo fooOne = new Foo(bus, entityId);
    Foo fooTwo = new Foo(bus, UUID.randomUUID());
   
    bus.register(fooOne, entityId);
    bus.send("blah", entityId);
   
    assertEquals("blah", fooOne.fooValue);
    assertEquals(null, fooTwo.fooValue);
View Full Code Here

Examples of org.serviceconnector.api.srv.SCPublishServer.register()

60
61
62
63
64
65
66
67
68
69
70
        int maxSessions = 10;
        int maxConnections = 5;
        SCPublishServerCallback cbk = new SrvCallback(publishSrv);

        publishSrv.register(maxSessions, maxConnections, cbk);
      } catch (Exception e) {
        publishSrv.deregister();
        throw e;
      }
    } catch (Exception e) {
View Full Code Here

Examples of org.serviceconnector.api.srv.SCSessionServer.register()

61
62
63
64
65
66
67
68
69
70
71
      SCSessionServer server = sc.newSessionServer(serviceName); // no other params possible
      int maxSess = 100;
      int maxConn = 10;
      SCSessionServerCallback cbk = newSrvCallback(server);
      try {
        server.register(maxSess, maxConn, cbk); // regular
        // server.registerServer(10, maxSess, maxConn, cbk); //
        // alternative with operation timeout
      } catch (Exception e) {
        LOGGER.error("runSessionServer", e);
        server.deregister();
View Full Code Here

Examples of org.sindice.siren.analysis.filter.DatatypeAnalyzerFilter.register()

97
98
99
100
101
102
103
104
105
106
107
  protected TokenStreamComponents createComponents(final String fieldName, final Reader reader) {
    final JsonTokenizer source = new JsonTokenizer(reader);

    final DatatypeAnalyzerFilter tt = new DatatypeAnalyzerFilter(matchVersion, source, fieldAnalyzer, valueAnalyzer);
    for (final Entry<Object, Analyzer> e : regAnalyzers.entrySet()) {
      tt.register((char[]) e.getKey(), e.getValue());
    }
    TokenStream sink = new PositionAttributeFilter(tt);
    sink = new SirenPayloadFilter(sink);
    return new TokenStreamComponents(source, sink);
  }
View Full Code Here

Examples of org.sindice.siren.solr.analysis.DatatypeAnalyzerFilterFactory.register()

339
340
341
342
343
344
345
346
347
348
349
    final TokenFilterFactory[] old = chain.getTokenFilterFactories();
    final TokenFilterFactory[] filterFactories = new TokenFilterFactory[old.length + 3];
    System.arraycopy(old, 0, filterFactories, 0, old.length);
    // append the datatype analyzer filter factory
    final DatatypeAnalyzerFilterFactory datatypeFactory = new DatatypeAnalyzerFilterFactory(luceneDefaultVersion);
    datatypeFactory.register(datatypes);
    filterFactories[old.length] = datatypeFactory;
    // append the position attribute filter factory
    filterFactories[old.length + 1] = new PositionAttributeFilterFactory();
    // append the siren payload filter factory
    filterFactories[old.length + 2] = new SirenPayloadFilterFactory();
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.