Examples of register()

Examples of org.apache.qpid.server.signal.SignalHandlerTask.register()

169
170
171
172
173
174
175
176
177
178
179
                    _logger.error("Could not reload configuration file security sections", e);
                }
            }
        };

        if(!hupReparseTask.register("HUP"))
        {
            _logger.info("Unable to register Signal HUP handler to reload security configuration.");
            _logger.info("Signal HUP not supported for this OS / JVM combination - " + SignalHandlerTask.getPlatformDescription());
        }
    }
View Full Code Here

Examples of org.apache.servicemix.document.DocumentRepository.register()

89
90
91
92
93
94
95
96
97
98
99
            if (ref == null) {
                throw new IllegalStateException("Can not get a reference to the DocumentRepository");
            }
            try {
                DocumentRepository rep = (DocumentRepository) bundleContext.getService(ref);
                this.documentId = rep.register(document.getBytes());
            } finally {
                if (ref != null) {
                    bundleContext.ungetService(ref);
                }
            }
View Full Code Here

Examples of org.apache.servicemix.jbi.runtime.impl.ComponentRegistryImpl.register()

73
74
75
76
77
78
79
80
81
82
83
        smx.getListenerRegistry().register(listener, new HashMap<String, Object>());
        // Create components
        provider = new TestComponent(new QName("provider"), "endpoint");
        consumer = new TestComponent(new QName("consumer"), "endpoint");
        // Register components
        reg.register(new SimpleComponentWrapper(provider), ServiceHelper.createMap(ComponentRegistry.NAME, "provider"));
        reg.register(new SimpleComponentWrapper(consumer), ServiceHelper.createMap(ComponentRegistry.NAME, "consumer"));
    }

    public void tearDown() throws Exception {
        if (listener != null) {
View Full Code Here

Examples of org.apache.servicemix.nmr.api.WireRegistry.register()

35
36
37
38
39
40
41
42
43
44
45
        Map<String, Object> properties = new HashMap<String, Object>();
        properties.put("wire-length", 12);
        properties.put("wire-type", "coton");
       
        WireRegistry registry = new WireRegistryImpl();
        registry.register(wire, properties);
        assertEquals(1, registry.getServices().size());
        assertEquals(properties, registry.getProperties(wire));
       
        assertSame(wire, registry.getWire(properties));
       
View Full Code Here

Examples of org.apache.sling.replication.trigger.ReplicationTrigger.register()

79
80
81
82
83
84
85
86
87
88
89
            public void handle(@Nonnull ReplicationRequest request) {
                writeEvent(writer, request);
            }
        };
        try {
            replicationTrigger.register(replicationRequestHandler);

            try {
                Thread.sleep(seconds * 1000);
            } catch (InterruptedException e) {
                log.error("thread interrupted", e);
View Full Code Here

Examples of org.apache.sling.servlets.post.impl.helper.DateParser.register()

429
430
431
432
433
434
435
436
437
438
439
        final DateParser dateParser = new DateParser();
        final String[] dateFormats = OsgiUtil.toStringArray(configuration.get(PROP_DATE_FORMAT));
        for (String dateFormat : dateFormats) {
            try {
                dateParser.register(dateFormat);
            } catch (Throwable t) {
                log.warn(
                    "configure: Ignoring DateParser format {} because it is invalid: {}",
                    dateFormat, t);
            }
View Full Code Here

Examples of org.apache.solr.core.CoreContainer.register()

113
114
115
116
117
118
119
120
121
122
123
      CoreContainer cores = new CoreContainer(new SolrResourceLoader(instanceDir));
      SolrConfig solrConfig = new SolrConfig(instanceDir, SolrConfig.DEFAULT_CONF_FILE, null);
      CoreDescriptor dcore = new CoreDescriptor(cores, "", solrConfig.getResourceLoader().getInstanceDir());
      IndexSchema indexSchema = new IndexSchema(solrConfig, instanceDir+"/conf/schema.xml", null);
      core = new SolrCore( null, dataDir, solrConfig, indexSchema, dcore);
      cores.register("", core, false);
      parser = new SolrRequestParsers( solrConfig );
    }
    catch (Exception ee) {
      throw new RuntimeException(ee);
    }
View Full Code Here

Examples of org.apache.solr.search.SolrIndexSearcher.register()

1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
          log.error("Ignoring searcher register on closed core:" + newSearcher);
          _searcher.decref();
        }
        ***/

        newSearcher.register(); // register subitems (caches)
        log.info(logid+"Registered new searcher " + newSearcher);

      } catch (Throwable e) {
        log(e);
      } finally {
View Full Code Here

Examples of org.apache.struts.digester.Digester.register()

1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
1118
  // Register our local copy of the DTDs that we can find
        for (int i = 0; i < registrations.length; i += 2) {
            URL url = this.getClass().getResource(registrations[i+1]);
            if (url != null)
                digester.register(registrations[i], url.toString());
        }

  // Configure the processing rules

        digester.addObjectCreate("struts-config/data-sources/data-source",
View Full Code Here

Examples of org.apache.tajo.worker.InterDataRetriever.register()

105
106
107
108
109
110
111
112
113
114
115
    InterDataRetriever ret = new InterDataRetriever();
    HttpDataServer server = new HttpDataServer(
        NetUtils.createSocketAddr("127.0.0.1:0"), ret);
    server.start();
   
    ret.register(qid1, qid1Dir.getPath());
    ret.register(qid2, qid2Dir.getPath());   
   
    InetSocketAddress addr = server.getBindAddress();
   
    assertDataRetrival(qid1, addr.getPort(), watermark1);
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.