Java ConfigurationImpl类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.activemq.artemis.core.config.impl.ConfigurationImpl类的典型用法代码示例。如果您正苦于以下问题：Java ConfigurationImpl类的具体用法？Java ConfigurationImpl怎么用？Java ConfigurationImpl使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ConfigurationImpl类属于org.apache.activemq.artemis.core.config.impl包，在下文中一共展示了ConfigurationImpl类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: buildArtemisBroker

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public ActiveMQServer buildArtemisBroker() throws IOException {
    Configuration configuration = new ConfigurationImpl();

    configuration.setPersistenceEnabled(true);
    configuration.setSecurityEnabled(false);

    Map<String, Object> connectionParams = new HashMap<String, Object>();
    connectionParams.put(
            org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants.PORT_PROP_NAME, 61400);

    configuration.setBindingsDirectory(storeFolder.newFolder().getAbsolutePath());
    configuration.setJournalDirectory(storeFolder.newFolder().getAbsolutePath());
    configuration.setLargeMessagesDirectory(storeFolder.newFolder().getAbsolutePath());
    configuration.setPagingDirectory(storeFolder.newFolder().getAbsolutePath());

    configuration.addAcceptorConfiguration(
            new TransportConfiguration(NettyAcceptorFactory.class.getName(), connectionParams));
    configuration.addConnectorConfiguration("connector",
            new TransportConfiguration(NettyConnectorFactory.class.getName(), connectionParams));


   return new ActiveMQServerImpl(configuration);
}

开发者ID:apache，项目名称:activemq-cli-tools，代码行数:24，代码来源:ExporterTest.java

示例2: before

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
@Before
public void before() throws Exception {
  mockTracer.reset();

  org.apache.activemq.artemis.core.config.Configuration configuration = new ConfigurationImpl();

  HashSet<TransportConfiguration> transports = new HashSet<>();
  transports.add(new TransportConfiguration(InVMAcceptorFactory.class.getName()));
  configuration.setAcceptorConfigurations(transports);
  configuration.setSecurityEnabled(false);

  File targetDir = new File(System.getProperty("user.dir") + "/target");
  configuration.setBrokerInstance(targetDir);

  server = new ActiveMQServerImpl(configuration);
  server.start();
  ActiveMQJMSConnectionFactory connectionFactory = new ActiveMQJMSConnectionFactory("vm://0");
  connection = connectionFactory.createConnection();

  connection.start();

  session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
}

开发者ID:opentracing-contrib，项目名称:java-jms，代码行数:24，代码来源:TracingArtemisTest.java

示例3: start

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public void start() throws Exception {
  org.apache.activemq.artemis.core.config.Configuration configuration = new ConfigurationImpl();

  HashSet<TransportConfiguration> transports = new HashSet<>();
  transports.add(new TransportConfiguration(InVMAcceptorFactory.class.getName()));
  configuration.setAcceptorConfigurations(transports);
  configuration.setSecurityEnabled(false);

  File targetDir = new File(System.getProperty("user.dir") + "/target");
  configuration.setBrokerInstance(targetDir);

  ActiveMQServer temp = new ActiveMQServerImpl(configuration);
  temp.start();

  server = temp;
}

开发者ID:opentracing-contrib，项目名称:java-spring-cloud，代码行数:17，代码来源:JmsArtemisManualServerTest.java

示例4: createConfiguration

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public Configuration createConfiguration() {
	ConfigurationImpl configuration = new ConfigurationImpl();
	configuration.setSecurityEnabled(false);
	configuration.setPersistenceEnabled(this.properties.isPersistent());
	String dataDir = getDataDir();
	configuration.setJournalDirectory(dataDir + "/journal");
	if (this.properties.isPersistent()) {
		configuration.setJournalType(JournalType.NIO);
		configuration.setLargeMessagesDirectory(dataDir + "/largemessages");
		configuration.setBindingsDirectory(dataDir + "/bindings");
		configuration.setPagingDirectory(dataDir + "/paging");
	}
	TransportConfiguration transportConfiguration = new TransportConfiguration(
			InVMAcceptorFactory.class.getName(),
			this.properties.generateTransportParameters());
	configuration.getAcceptorConfigurations().add(transportConfiguration);
	if (this.properties.isDefaultClusterPassword()) {
		logger.debug("Using default Artemis cluster password: "
				+ this.properties.getClusterPassword());
	}
	configuration.setClusterPassword(this.properties.getClusterPassword());
	return configuration;
}

开发者ID:vikrammane23，项目名称:https-github.com-g0t4-jenkins2-course-spring-boot，代码行数:24，代码来源:ArtemisEmbeddedConfigurationFactory.java

示例5: start

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public void start() throws Exception {
    Configuration config = new ConfigurationImpl();

    Map<String, Object> params = new LinkedHashMap<>();
    params.put("protocols", "AMQP");
    params.put("host", host);
    params.put("port", port);
    TransportConfiguration transport = new TransportConfiguration(NettyAcceptorFactory.class.getName(), params, "amqp");

    config.setAcceptorConfigurations(Collections.singleton(transport));
    config.setSecurityEnabled(false);
    config.setName("broker-" + System.currentTimeMillis() + port);
    config.setBindingsDirectory(Files.createTempDir().getAbsolutePath());
    config.setJournalDirectory(Files.createTempDir().getAbsolutePath());
    config.setPagingDirectory(Files.createTempDir().getAbsolutePath());
    config.setLargeMessagesDirectory(Files.createTempDir().getAbsolutePath());
    config.setPersistenceEnabled(false);

    server.setConfiguration(config);

    server.start();
    Thread.sleep(2000);
}

开发者ID:EnMasseProject，项目名称:enmasse，代码行数:24，代码来源:TestArtemis.java

示例6: createConfiguration

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public Configuration createConfiguration() {
	ConfigurationImpl configuration = new ConfigurationImpl();
	configuration.setSecurityEnabled(false);
	configuration.setPersistenceEnabled(this.properties.isPersistent());
	String dataDir = getDataDir();
	configuration.setJournalDirectory(dataDir + "/journal");
	if (this.properties.isPersistent()) {
		configuration.setJournalType(JournalType.NIO);
		configuration.setLargeMessagesDirectory(dataDir + "/largemessages");
		configuration.setBindingsDirectory(dataDir + "/bindings");
		configuration.setPagingDirectory(dataDir + "/paging");
	}
	TransportConfiguration transportConfiguration = new TransportConfiguration(
			InVMAcceptorFactory.class.getName(),
			this.properties.generateTransportParameters());
	configuration.getAcceptorConfigurations().add(transportConfiguration);
	if (this.properties.isDefaultClusterPassword()) {
		this.logger.debug("Using default Artemis cluster password: "
				+ this.properties.getClusterPassword());
	}
	configuration.setClusterPassword(this.properties.getClusterPassword());
	return configuration;
}

开发者ID:Nephilim84，项目名称:contestparser，代码行数:24，代码来源:ArtemisEmbeddedConfigurationFactory.java

示例7: setup

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
@BeforeClass
public static void setup() throws Exception {
   Configuration configuration = new ConfigurationImpl().setPersistenceEnabled(false).setSecurityEnabled(false).addAcceptorConfiguration(new TransportConfiguration(InVMAcceptorFactory.class.getName()));

   activeMQServer = ActiveMQServers.newActiveMQServer(configuration);
   activeMQServer.start();

   HashMap<String, Object> transportConfig = new HashMap<>();

   serverLocator = new ServerLocatorImpl(false, new TransportConfiguration(InVMConnectorFactory.class.getName(), transportConfig));
   sessionFactory = serverLocator.createSessionFactory();
   consumerSessionFactory = serverLocator.createSessionFactory();

   SimpleString addr = SimpleString.toSimpleString("testQueue");
   activeMQServer.addAddressInfo(new AddressInfo(addr, RoutingType.MULTICAST));
   activeMQServer.createQueue(addr, RoutingType.MULTICAST, addr, null, false, false);
   session = sessionFactory.createSession(true, true);
   producer = session.createProducer(addr);
   session.start();
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:21，代码来源:RawAckTest.java

示例8: process

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public void process(OutputStream out,
                    String bindingsDir,
                    String journalDir,
                    String pagingDir,
                    String largeMessagesDir) throws Exception {
   config = new ConfigurationImpl().setBindingsDirectory(bindingsDir).setJournalDirectory(journalDir).setPagingDirectory(pagingDir).setLargeMessagesDirectory(largeMessagesDir).setJournalType(JournalType.NIO);
   final ExecutorService executor = Executors.newFixedThreadPool(5, ActiveMQThreadFactory.defaultThreadFactory());
   ExecutorFactory executorFactory = new OrderedExecutorFactory(executor);

   storageManager = new JournalStorageManager(config, EmptyCriticalAnalyzer.getInstance(), executorFactory, executorFactory);

   XMLOutputFactory factory = XMLOutputFactory.newInstance();
   XMLStreamWriter rawXmlWriter = factory.createXMLStreamWriter(out, "UTF-8");
   PrettyPrintHandler handler = new PrettyPrintHandler(rawXmlWriter);
   xmlWriter = (XMLStreamWriter) Proxy.newProxyInstance(XMLStreamWriter.class.getClassLoader(), new Class[]{XMLStreamWriter.class}, handler);

   writeXMLData();

   executor.shutdown();
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:21，代码来源:XmlDataExporter.java

示例9: createSecondaryDefaultConfig

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
protected Configuration createSecondaryDefaultConfig(boolean secondary) throws Exception {
   HashMap<String, Object> invmMap = new HashMap<>();
   HashMap<String, Object> nettyMap = new HashMap<>();
   String primaryConnectorName = "invm2";
   String secondaryConnectorName = "invm";
   int index = 0;

   if (secondary) {
      invmMap.put(TransportConstants.SERVER_ID_PROP_NAME, "1");
      nettyMap.put("port", "5545");
      primaryConnectorName = "invm";
      secondaryConnectorName = "invm2";
      index = 1;
   }

   ConfigurationImpl configuration = createBasicConfig(index).setJMXManagementEnabled(false).clearAcceptorConfigurations().addAcceptorConfiguration(new TransportConfiguration(INVM_ACCEPTOR_FACTORY, invmMap)).addAcceptorConfiguration(new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, nettyMap)).addConnectorConfiguration(secondaryConnectorName, secondaryConnector).addConnectorConfiguration(primaryConnectorName, primaryConnector).addClusterConfiguration(ActiveMQTestBase.basicClusterConnectionConfig(secondaryConnectorName, primaryConnectorName).setReconnectAttempts(0));

   recreateDataDirectories(getTestDir(), index, false);

   return configuration;
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:22，代码来源:ActiveMQRAClusteredTestBase.java

示例10: setUp

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
   locator = ActiveMQClient.createServerLocatorWithoutHA(new TransportConfiguration(InVMConnectorFactory.class.getCanonicalName()));
   testDir = temporaryFolder.getRoot().getAbsolutePath();

   LegacyLDAPSecuritySettingPlugin legacyLDAPSecuritySettingPlugin = new LegacyLDAPSecuritySettingPlugin();
   Map<String, String> map = new HashMap<>();
   map.put(LegacyLDAPSecuritySettingPlugin.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.ldap.LdapCtxFactory");
   map.put(LegacyLDAPSecuritySettingPlugin.CONNECTION_URL, "ldap://localhost:1024");
   map.put(LegacyLDAPSecuritySettingPlugin.CONNECTION_USERNAME, "uid=admin,ou=system");
   map.put(LegacyLDAPSecuritySettingPlugin.CONNECTION_PASSWORD, "secret");
   map.put(LegacyLDAPSecuritySettingPlugin.CONNECTION_PROTOCOL, "s");
   map.put(LegacyLDAPSecuritySettingPlugin.AUTHENTICATION, "simple");
   map.put(LegacyLDAPSecuritySettingPlugin.ENABLE_LISTENER, "true");
   legacyLDAPSecuritySettingPlugin.init(map);

   ActiveMQJAASSecurityManager securityManager = new ActiveMQJAASSecurityManager("LDAPLogin");
   Configuration configuration = new ConfigurationImpl().setSecurityEnabled(true).addAcceptorConfiguration(new TransportConfiguration(InVMAcceptorFactory.class.getCanonicalName())).setJournalDirectory(ActiveMQTestBase.getJournalDir(testDir, 0, false)).setBindingsDirectory(ActiveMQTestBase.getBindingsDir(testDir, 0, false)).setPagingDirectory(ActiveMQTestBase.getPageDir(testDir, 0, false)).setLargeMessagesDirectory(ActiveMQTestBase.getLargeMessagesDir(testDir, 0, false)).setPersistenceEnabled(false).addSecuritySettingPlugin(legacyLDAPSecuritySettingPlugin);

   server = ActiveMQServers.newActiveMQServer(configuration, ManagementFactory.getPlatformMBeanServer(), securityManager, false);
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:22，代码来源:LegacyLDAPSecuritySettingPluginListenerTest.java

示例11: setUp

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
@Override
@Before
public void setUp() throws Exception {
   super.setUp();
   Map<String, Object> params = new HashMap<>();
   params.put(TransportConstants.SSL_ENABLED_PROP_NAME, true);
   params.put(TransportConstants.KEYSTORE_PATH_PROP_NAME, SERVER_SIDE_KEYSTORE);
   params.put(TransportConstants.KEYSTORE_PASSWORD_PROP_NAME, PASSWORD);
   params.put(TransportConstants.TRUSTSTORE_PATH_PROP_NAME, SERVER_SIDE_TRUSTSTORE);
   params.put(TransportConstants.TRUSTSTORE_PASSWORD_PROP_NAME, PASSWORD);
   params.put(TransportConstants.TRUSTSTORE_PROVIDER_PROP_NAME, storeType);
   params.put(TransportConstants.KEYSTORE_PROVIDER_PROP_NAME, storeType);
   params.put(TransportConstants.NEED_CLIENT_AUTH_PROP_NAME, true);
   ConfigurationImpl config = createBasicConfig().addAcceptorConfiguration(new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, params, "nettySSL"));
   server = createServer(false, config);
   server.start();
   waitForServerToStart(server);
   tc = new TransportConfiguration(NETTY_CONNECTOR_FACTORY);
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:20，代码来源:CoreClientOverTwoWaySSLTest.java

示例12: setUp

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
@Override
@Before
public void setUp() throws Exception {
   super.setUp();

   ConfigurationImpl configuration = (ConfigurationImpl) createDefaultInVMConfig().setMessageExpiryScanPeriod(1000);
   server = addServer(ActiveMQServers.newActiveMQServer(configuration, false));
   // start the server
   server.start();
   // then we create a client as normal
   locator = createInVMNonHALocator().setBlockOnAcknowledge(true);

   ClientSessionFactory sessionFactory = createSessionFactory(locator);

   clientSession = sessionFactory.createSession(false, true, true);
   clientSession.createQueue(qName, RoutingType.MULTICAST, qName, null, false);
   expiryAddress = new SimpleString("EA");
   expiryQueue = new SimpleString("expiryQ");
   AddressSettings addressSettings = new AddressSettings().setExpiryAddress(expiryAddress);
   server.getAddressSettingsRepository().addMatch(qName.toString(), addressSettings);
   server.getAddressSettingsRepository().addMatch(qName2.toString(), addressSettings);
   clientSession.createQueue(expiryAddress, RoutingType.MULTICAST, expiryQueue, null, false);
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:24，代码来源:ExpiryRunnerTest.java

示例13: createConfig

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
protected Configuration createConfig(final String hostAddress, final int serverID, final int port) throws Exception {
   ConfigurationImpl configuration = new ConfigurationImpl().setJMXManagementEnabled(false).
      setSecurityEnabled(false).setJournalMinFiles(2).setJournalFileSize(1000 * 1024).setJournalType(JournalType.NIO).
      setJournalDirectory(getJournalDir(serverID, false)).
      setBindingsDirectory(getBindingsDir(serverID, false)).
      setPagingDirectory(getPageDir(serverID, false)).
      setLargeMessagesDirectory(getLargeMessagesDir(serverID, false)).
      setJournalCompactMinFiles(0).
      setJournalCompactPercentage(0).
      setClusterPassword(CLUSTER_PASSWORD);

   configuration.addAddressesSetting("#", new AddressSettings().setAutoCreateJmsQueues(true).setAutoDeleteJmsQueues(true));

   configuration.addAcceptorConfiguration("netty", newURIwithPort(hostAddress, port));
   configuration.addConnectorConfiguration("netty-connector", newURIwithPort(hostAddress, port));

   return configuration;
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:19，代码来源:OpenwireArtemisBaseTest.java

示例14: createConfig

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
protected Configuration createConfig(final String hostAddress, final int serverID) throws Exception {
   ConfigurationImpl configuration = new ConfigurationImpl().setJMXManagementEnabled(false).
      setSecurityEnabled(false).setJournalMinFiles(2).setJournalFileSize(1000 * 1024).setJournalType(JournalType.NIO).
      setJournalDirectory(getJournalDir(serverID, false)).
      setBindingsDirectory(getBindingsDir(serverID, false)).
      setPagingDirectory(getPageDir(serverID, false)).
      setLargeMessagesDirectory(getLargeMessagesDir(serverID, false)).
      setJournalCompactMinFiles(0).
      setJournalCompactPercentage(0).
      setClusterPassword(CLUSTER_PASSWORD);

   configuration.addAddressesSetting("#", new AddressSettings().setAutoCreateJmsQueues(true).setAutoDeleteJmsQueues(true));

   configuration.addAcceptorConfiguration("netty", newURI(hostAddress, serverID));
   configuration.addConnectorConfiguration("netty-connector", newURI(hostAddress, serverID));

   return configuration;
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:19，代码来源:EmbeddedBrokerTestSupport.java

示例15: startServer

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public static ActiveMQServer startServer() throws Exception {
   if (server == null) {
      Configuration config = new ConfigurationImpl().addAcceptorConfiguration("netty", "tcp://localhost:61616").setSecurityEnabled(false).addConnectorConfiguration("netty", "tcp://localhost:61616");
      File dataPlace = new File("./target/dataJoram");

      FileUtil.deleteDirectory(dataPlace);

      config.setJournalDirectory(new File(dataPlace, "./journal").getAbsolutePath()).
         setPagingDirectory(new File(dataPlace, "./paging").getAbsolutePath()).
         setLargeMessagesDirectory(new File(dataPlace, "./largemessages").getAbsolutePath()).
         setBindingsDirectory(new File(dataPlace, "./bindings").getAbsolutePath()).setPersistenceEnabled(true);

      // disable server persistence since JORAM tests do not restart server
      server = ActiveMQServers.newActiveMQServer(config, useFiles);

      serverManager = new JMSServerManagerImpl(server);
      serverManager.start();
   }
   return server;
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:21，代码来源:SpawnedJMSServer.java

示例16: EmbeddedJMSResource

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
/**
 * Create a default EmbeddedJMSResource
 */
public EmbeddedJMSResource(boolean useNetty) {
   try {
      configuration = new ConfigurationImpl().setName(SERVER_NAME).setPersistenceEnabled(false).setSecurityEnabled(false).addAcceptorConfiguration("invm", "vm://0");

      if (useNetty) {
         configuration.addAcceptorConfiguration("netty", DefaultConnectionProperties.DEFAULT_BROKER_BIND_URL);
      }

      jmsConfiguration = new JMSConfigurationImpl();

      init();
   } catch (Exception e) {
      throw new RuntimeException(e);
   }
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:19，代码来源:EmbeddedJMSResource.java

示例17: parseMainConfig

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public Configuration parseMainConfig(final InputStream input) throws Exception {
   Reader reader = new InputStreamReader(input);
   String xml = XMLUtil.readerToString(reader);
   xml = XMLUtil.replaceSystemProps(xml);
   Element e = XMLUtil.stringToElement(xml);
   SchemaFactory schemaFactory = SchemaFactory.newInstance(XMLConstants.W3C_XML_SCHEMA_NS_URI);
   Schema schema = schemaFactory.newSchema(XMLUtil.findResource("schema/artemis-server.xsd"));
   Validator validator = schema.newValidator();
   try {
      validator.validate(new DOMSource(e));
   } catch (Exception ex) {
      ActiveMQServerLogger.LOGGER.error(ex.getMessage());
   }
   Configuration config = new ConfigurationImpl();
   parseMainConfig(e, config);

   return config;
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:19，代码来源:FileConfigurationParser.java

示例18: getConfiguration

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
/**
 * @return the configuration for usage in the broker.
 */
public Configuration getConfiguration() {
	final Map<String, Object> params = Collections.singletonMap(SERVER_ID_PROP_NAME, "1");
	final Configuration config = new ConfigurationImpl().setPersistenceEnabled(false);
	// default In VM Acceptor for all your ConnectionFactory needs
	config.addAcceptorConfiguration(new TransportConfiguration(IN_VM_ACCEPTOR, params, "InVMAcceptor"));
	return config;
}

开发者ID:dansiviter，项目名称:cito，代码行数:11，代码来源:BrokerConfig.java

示例19: start

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public void start() throws Exception {
    Configuration config = new ConfigurationImpl();

    Map<String, Object> params = new LinkedHashMap<>();
    params.put("protocols", "AMQP,CORE");
    params.put("host", host);
    params.put("port", port);
    TransportConfiguration transport = new TransportConfiguration(NettyAcceptorFactory.class.getName(), params, "amqp");

    for (String address : addressList) {
        CoreAddressConfiguration addressConfig = new CoreAddressConfiguration();
        addressConfig.setName(address);
        CoreQueueConfiguration queueConfig = new CoreQueueConfiguration();
        queueConfig.setAddress(address);
        queueConfig.setRoutingType(multicast ? RoutingType.MULTICAST : RoutingType.ANYCAST);
        queueConfig.setName(address);
        addressConfig.addQueueConfiguration(queueConfig);
        config.addAddressConfiguration(addressConfig);
    }

    config.setAcceptorConfigurations(Collections.singleton(transport));
    config.setSecurityEnabled(false);
    config.setName("broker-" + System.currentTimeMillis() + port);
    config.setBindingsDirectory(Files.createTempDir().getAbsolutePath());
    config.setJournalDirectory(Files.createTempDir().getAbsolutePath());
    config.setPagingDirectory(Files.createTempDir().getAbsolutePath());
    config.setLargeMessagesDirectory(Files.createTempDir().getAbsolutePath());
    config.setPersistenceEnabled(false);

    server.setConfiguration(config);

    server.start();
    Thread.sleep(2000);
}

开发者ID:EnMasseProject，项目名称:enmasse，代码行数:35，代码来源:TestBroker.java

示例20: start

import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; //导入依赖的package包/类
public void start() throws Exception {
   System.out.println("\nStarting Embedded");
   if (activeMQServer == null) {
      Configuration configuration = new ConfigurationImpl().setPersistenceEnabled(false).setSecurityEnabled(false).addAcceptorConfiguration(new TransportConfiguration(InVMAcceptorFactory.class.getName()));

      activeMQServer = ActiveMQServers.newActiveMQServer(configuration);
      activeMQServer.start();
   }
   tjws.start();
   manager.setConfiguration(config);
   manager.start();
   tjws.getDeployment().getRegistry().addSingletonResource(manager.getQueueManager().getDestination());
   tjws.getDeployment().getRegistry().addSingletonResource(manager.getTopicManager().getDestination());

}

开发者ID:apache，项目名称:activemq-artemis，代码行数:16，代码来源:Embedded.java

注：本文中的org.apache.activemq.artemis.core.config.impl.ConfigurationImpl类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。