Package org.apache.qpid.server.configuration

Examples of org.apache.qpid.server.configuration.RecovererProvider

261
262
263
264
265
266
267
268
269
270
271
    {
        ConfigurationEntry pluginEntry = mock(ConfigurationEntry.class);
        KeyStore keyStore = mock(KeyStore.class);
        _brokerEntryChildren.put(KeyStore.class.getSimpleName(), Arrays.asList(pluginEntry));

        RecovererProvider recovererProvider = createRecoveryProvider(new ConfigurationEntry[]{pluginEntry, _authenticationProviderEntry1},
                                                                     new ConfiguredObject[]{keyStore, _authenticationProvider1});

        Broker broker = _brokerRecoverer.create(recovererProvider, _brokerEntry);

        assertNotNull(broker);
View Full Code Here
277
278
279
280
281
282
283
284
285
286
287
    {
        ConfigurationEntry pluginEntry = mock(ConfigurationEntry.class);
        TrustStore trustStore = mock(TrustStore.class);
        _brokerEntryChildren.put(TrustStore.class.getSimpleName(), Arrays.asList(pluginEntry));

        RecovererProvider recovererProvider = createRecoveryProvider(new ConfigurationEntry[]{pluginEntry, _authenticationProviderEntry1},
                                                                     new ConfiguredObject[]{trustStore, _authenticationProvider1});

        Broker broker = _brokerRecoverer.create(recovererProvider, _brokerEntry);

        assertNotNull(broker);
View Full Code Here
357
358
359
360
361
362
363
364
365
366
367
        return String.valueOf(attributeValue);
    }

    private  RecovererProvider createRecoveryProvider(final ConfigurationEntry[] entries, final ConfiguredObject[] objectsToRecoverer)
    {
        RecovererProvider recovererProvider = new RecovererProvider()
        {
            @Override
            public ConfiguredObjectRecoverer<? extends ConfiguredObject> getRecoverer(String type)
            {
                @SuppressWarnings({ "unchecked", "rawtypes" })
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
            logStartupMessages(CurrentActor.get());

            _taskExecutor = new TaskExecutor();
            _taskExecutor.start();

            RecovererProvider provider = new DefaultRecovererProvider((StatisticsGatherer)this, _virtualHostRegistry, _logRecorder, _rootMessageLogger, _taskExecutor, brokerOptions);
            ConfiguredObjectRecoverer<? extends ConfiguredObject> brokerRecoverer =  provider.getRecoverer(Broker.class.getSimpleName());
            _broker = (Broker) brokerRecoverer.create(provider, _store.getRootEntry());

            _virtualHostRegistry.setDefaultVirtualHostName((String)_broker.getAttribute(Broker.DEFAULT_VIRTUAL_HOST));

            initialiseStatisticsReporting();
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
116
117
        _taskExecutor = new TaskExecutor();
        _taskExecutor.start();

        StoreConfigurationChangeListener storeChangeListener = new StoreConfigurationChangeListener(_store);
        RecovererProvider provider = new DefaultRecovererProvider((StatisticsGatherer)this, _virtualHostRegistry, _logRecorder,
                                                                  _taskExecutor, brokerOptions, storeChangeListener);
        ConfiguredObjectRecoverer<? extends ConfiguredObject> brokerRecoverer =  provider.getRecoverer(Broker.class.getSimpleName());
        _broker = (Broker) brokerRecoverer.create(provider, _store.getRootEntry());
        _broker.setEventLogger(startupLogger);
        _virtualHostRegistry.setDefaultVirtualHostName((String)_broker.getAttribute(Broker.DEFAULT_VIRTUAL_HOST));

        initialiseStatisticsReporting();
View Full Code Here
TOP

Related Classes of org.apache.qpid.server.configuration.RecovererProvider

  • org.apache.qpid.server.configuration.startup.AuthenticationProviderRecovererTest
  • org.apache.qpid.server.configuration.startup.BrokerRecovererTest
  • org.apache.qpid.server.registry.ApplicationRegistry
    • 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.