Package org.glassfish.hk2.api

Examples of org.glassfish.hk2.api.DynamicConfiguration


                                "as the service object could not be obtained.", new Object[]{reference});
                return null;
            }
           
            DynamicConfigurationService dcs = serviceLocator.getService(DynamicConfigurationService.class);
            DynamicConfiguration config = dcs.createDynamicConfiguration();

            AbstractActiveDescriptor<Object> descriptor = BuilderHelper.createConstantDescriptor(object);
           
           
            // let's get the list of implemented contracts
            String[] contractNames = (String[]) reference.getProperty("objectclass");
            if (contractNames != null && contractNames.length > 0) {
                // we will register this service under each contract it implements
                for (String contractName : contractNames) {
                    String name = (String) reference.getProperty("component.name");
                    if (name == null) {
                        // let's get a name if possible, that will only work with Spring OSGi services
                        // we may need to find a better way to get a potential name.
                        name = (String) reference.getProperty("org.springframework.osgi.bean.name");
                    }
                     
                    try {
                        final Class<?> contractType =
                                Class.forName(contractName, false, object.getClass().getClassLoader());
                        descriptor.addContractType(contractType);
           
            if (name != null)
              descriptor.setName(name);

                      logger.logp(Level.FINE, "HK2Main$HK2ServiceTrackerCustomizer",
                              "addingService", "registering service = {0}, contract = {1}, name = {2}", new Object[]{
                                      object, contractName, name});
          } catch (ClassNotFoundException e) {
            logger.log(Level.SEVERE, "Cannot resolve contract " + contractName, e);
          }
                   
                }
               
            } else {
                // this service does not implement a specific contract, let's register it by its type.
                logger.logp(Level.FINE, "HK2Main$HK2ServiceTrackerCustomizer",
                        "addingService", "registering service = {0}", object);
            }
           
            config.addActiveDescriptor(descriptor);

            config.commit();

            return descriptor;
        }
View Full Code Here


        }

        public void removedService(ServiceReference reference, final Object service) {

            DynamicConfigurationService dcs = serviceLocator.getService(DynamicConfigurationService.class);
            DynamicConfiguration config = dcs.createDynamicConfiguration();
           
            org.glassfish.hk2.api.Filter filter = new org.glassfish.hk2.api.Filter() {

                @Override
                public boolean matches(Descriptor d) {
                    return d.equals(service); // addingServices() returns the descriptor
                }

            };

            config.addUnbindFilter(filter);

            config.commit();
        }
View Full Code Here

            logger.log(level, "Startup class : {0}", getClass().getName());
        }

        // prepare the global variables
        DynamicConfigurationService dcs = locator.getService(DynamicConfigurationService.class);
        DynamicConfiguration config = dcs.createDynamicConfiguration();

        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(this));
//        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(systemRegistry));
        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(logger));

        config.addUnbindFilter(BuilderHelper.createContractFilter(ProcessEnvironment.class.getName()));

        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(
                env.isEmbedded() ?
                new ProcessEnvironment(ProcessEnvironment.ProcessType.Embedded):
                new ProcessEnvironment(ProcessEnvironment.ProcessType.Server)));
        config.commit();

        // activate the run level services
        if (proceedTo(InitRunLevel.VAL, new InitActivator())) {
            if (proceedTo(StartupRunLevel.VAL, new StartupActivator())) {
                proceedTo(PostStartupRunLevel.VAL, new PostStartupActivator());
View Full Code Here

     * @return false if an error occurred that required server shutdown; true otherwise
     */
    private boolean proceedTo(int runLevel, AppServerActivator activator) {
        // set up the run level listener and activator
        DynamicConfigurationService dcs = locator.getService(DynamicConfigurationService.class);
        DynamicConfiguration config = dcs.createDynamicConfiguration();

        ActiveDescriptor<?> activatorDescriptor = config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(activator));

        config.commit();

        try {
            runLevelController.proceedTo(runLevel);
        } catch (Exception e) {
            logger.log(Level.SEVERE, "Shutdown required", e);
            shutdown();
            return false;
        } finally {
            config = dcs.createDynamicConfiguration();
            config.addUnbindFilter(BuilderHelper.createSpecificDescriptorFilter(activatorDescriptor));
            config.commit();
        }
        return !activator.isShutdown();
    }
View Full Code Here

        if (addService == false && addContext == false) return;
       
        DynamicConfigurationService dcs = locator.getService(DynamicConfigurationService.class);
        if (dcs == null) return;
       
        DynamicConfiguration config = dcs.createDynamicConfiguration();
       
        if (addService) {
            config.addActiveDescriptor(SpringIntoHK2BridgeImpl.class);
        }
       
        if (addContext) {
            config.addActiveDescriptor(SpringScopeContext.class);
        }
       
        config.commit();
    }
View Full Code Here

            logger.log(level, "Startup class : {0}", getClass().getName());
        }

        // prepare the global variables
        DynamicConfigurationService dcs = locator.getService(DynamicConfigurationService.class);
        DynamicConfiguration config = dcs.createDynamicConfiguration();

        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(this));
        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(masterListener));
        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(logger));

        config.addUnbindFilter(BuilderHelper.createContractFilter(ProcessEnvironment.class.getName()));

        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(
                env.isEmbedded() ?
                new ProcessEnvironment(ProcessEnvironment.ProcessType.Embedded):
                new ProcessEnvironment(ProcessEnvironment.ProcessType.Server)));
        config.commit();
       
        LinkedHashMap<String, Long> recordedTimes = new LinkedHashMap<String, Long>();

        // activate the run level services
        if (proceedTo(InitRunLevel.VAL, new InitActivator(recordedTimes))) {
View Full Code Here

        ServiceLocator locator = grizzlyService.getHabitat();
        IndexedFilter removeFilter = BuilderHelper.createNameAndContractFilter(Mapper.class.getName(),
                (address.toString() + port));

        DynamicConfigurationService dcs = locator.getService(DynamicConfigurationService.class);
        DynamicConfiguration config = dcs.createDynamicConfiguration();

        config.addUnbindFilter(removeFilter);

        config.commit();

        unregisterMonitoringStatsProviders();
        super.stop();
    }
View Full Code Here

            logger.log(level, "Startup class : {0}", getClass().getName());
        }

        // prepare the global variables
        DynamicConfigurationService dcs = locator.getService(DynamicConfigurationService.class);
        DynamicConfiguration config = dcs.createDynamicConfiguration();

        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(this));
        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(masterListener));
        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(logger));

        config.addUnbindFilter(BuilderHelper.createContractFilter(ProcessEnvironment.class.getName()));

        config.addActiveDescriptor(BuilderHelper.createConstantDescriptor(
                env.isEmbedded() ?
                new ProcessEnvironment(ProcessEnvironment.ProcessType.Embedded):
                new ProcessEnvironment(ProcessEnvironment.ProcessType.Server)));
        config.commit();

        // activate the run level services
        if (proceedTo(InitRunLevel.VAL, new InitActivator())) {
            if (proceedTo(StartupRunLevel.VAL, new StartupActivator())) {
                proceedTo(PostStartupRunLevel.VAL, new PostStartupActivator());
View Full Code Here

    @Test
    public void testConfigure() throws Exception {

        BootstrapBinder binder = new BootstrapBinder();
        DynamicConfiguration dynamicConfiguration = mock(DynamicConfiguration.class);
        binder.bind(dynamicConfiguration);

    }
View Full Code Here

    @Test
    public void testConfigure() throws Exception {

        InternalVertxJerseyBinder binder = new InternalVertxJerseyBinder(mock(Vertx.class));
        DynamicConfiguration dynamicConfiguration = mock(DynamicConfiguration.class);
        binder.bind(dynamicConfiguration);

    }
View Full Code Here

TOP

Related Classes of org.glassfish.hk2.api.DynamicConfiguration

Copyright © 2018 www.massapicom. 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.