Examples of register()

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

53
54
55
56
57
58
59
60
61
62
63
   @Provides
   @Singleton
   AsyncEventBus provideAsyncEventBus(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor,
         DeadEventLoggingHandler deadEventsHandler) {// NO_UCD
      AsyncEventBus asyncBus = new AsyncEventBus("jclouds-async-event-bus", userExecutor);
      asyncBus.register(deadEventsHandler);
      return asyncBus;
   }

   /**
    * Provides asynchronous {@link EventBus}.
View Full Code Here

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

287
288
289
290
291
292
293
294
295
296
297
          PollingZooKeeperConfigurationProvider zookeeperConfigurationProvider =
            new PollingZooKeeperConfigurationProvider(
              agentName, zkConnectionStr, baseZkPath, eventBus);
          components.add(zookeeperConfigurationProvider);
          application = new Application(components);
          eventBus.register(application);
        } else {
          StaticZooKeeperConfigurationProvider zookeeperConfigurationProvider =
            new StaticZooKeeperConfigurationProvider(
              agentName, zkConnectionStr, baseZkPath);
          application = new Application();
View Full Code Here

Examples of com.google.common.io.Closer.register()

72
73
74
75
76
77
78
79
80
81
82
    public Object addingService(ServiceReference reference) {
        Object service = bundleContext.getService(reference);

        if (service instanceof Observer) {
            Closer subscription = Closer.create();
            BackgroundObserver observer = subscription.register(
                    new BackgroundObserver((Observer) service, executor));
            subscription.register(
                    observable.addObserver(observer));
            subscriptions.put(reference, subscription);
            return service;
View Full Code Here

Examples of com.google.feedserver.util.BeanCliHelper.register()

87
88
89
90
91
92
93
94
95
96
97
    LOG.info("Agent handshake version = " + SdcConnection.INITIAL_HANDSHAKE_MSG);

    // validate the localConf.xml file and the input args
    try {
      BeanCliHelper beanCliHelper = new BeanCliHelper();
      beanCliHelper.register(localConf);
      beanCliHelper.parse(args);
      new LocalConfValidator().validate(localConf);
    } catch (LocalConfException e) {
      LOG.fatal("Configuration error", e);
      return;
View Full Code Here

Examples of com.google.feedserver.util.CommonsCliHelper.register()

139
140
141
142
143
144
145
146
147
148
149
   * @return The client helper
   */
  @SuppressWarnings("unchecked")
  protected CommonsCliHelper createClientHelper(String[] args, Class clazz) {
    CommonsCliHelper cliHelper = new CommonsCliHelper();
    cliHelper.register(clazz);
    cliHelper.parse(args);

    return cliHelper;
  }

View Full Code Here

Examples of com.google.gwt.place.shared.PlaceHistoryHandler.register()

50
51
52
53
54
55
56
57
58
59
60
        activityManager.setDisplay(display);

        // Start PlaceHistoryHandler with our PlaceHistoryMapper
        PresenterPlaceHistoryMapper historyMapper= GWT.create(PresenterPlaceHistoryMapper.class);
        PlaceHistoryHandler historyHandler = new PlaceHistoryHandler(historyMapper);
        historyHandler.register(placeController, eventBus, defaultPlace);

        RootLayoutPanel.get().add(display);
        // Goes to the place represented on URL else default place
        historyHandler.handleCurrentHistory();
  }
View Full Code Here

Examples of com.google.inject.spi.TypeEncounter.register()

30
31
32
33
34
35
36
37
38
39
40
public class LifecycleTypeListenerTest {
    @Test
    public void testHearInitializable() throws Exception {
        TypeEncounter encounter = createMock(TypeEncounter.class);

        encounter.register(anyObject(InitializableInjectionListener.class));

        replay(encounter);

        LifecycleTypeListener underTest = new LifecycleTypeListener(null);
View Full Code Here

Examples of com.google.k2crypto.keyversions.KeyVersionRegistry.register()

69
70
71
72
73
74
75
76
77
78
79
    K2Storage storage = new K2Storage(context);
   
    // Register available key versions
    KeyVersionRegistry registry = context.getKeyVersionRegistry();
    try {
      registry.register(AESKeyVersion.class);
      registry.register(HMACKeyVersion.class);
    } catch (KeyVersionException ex) {
      // Something wrong with a key version
      throw ex;
    }
View Full Code Here

Examples of com.google.nigori.client.Datastore.register()

40
41
42
43
44
45
46
47
48
49
50
  @Test
  public void test() throws NigoriCryptographyException, IOException, UnauthorisedException {
    Datastore nigori = getStore();
    for (int i = 0; i < AcceptanceTests.REPEAT; ++i) {// check we can do this more than once
      assertTrue("Not registered", nigori.register());
      assertTrue("Can't authenticate", nigori.authenticate());
      assertTrue("Can't unregister", nigori.unregister());
      assertFalse("Authenticated after unregistration", nigori.authenticate());
      assertFalse("Could re-unregister", nigori.unregister());
    }
View Full Code Here

Examples of com.google.nigori.client.MigoriDatastore.register()

35
36
37
38
39
40
41
42
43
44
45
public class MSetGetTest extends AcceptanceTest {

  @Test
  public void putGraph() throws NigoriCryptographyException, IOException, UnauthorisedException {
    MigoriDatastore store = getStore();
    store.register();
    try {
      Index index = new Index("test");
      RevValue a = store.put(index, "a".getBytes());
      RevValue b = store.put(index, "b".getBytes(), a);
      RevValue c = store.put(index, "c".getBytes(), a);
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.