Java EmbeddedJMS类代码示例

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

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

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

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

示例1: embeddedConnectionFactory

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Test
public void embeddedConnectionFactory() {
	load(EmptyConfiguration.class, "spring.hornetq.mode:embedded");

	HornetQProperties properties = this.context.getBean(HornetQProperties.class);
	assertThat(properties.getMode()).isEqualTo(HornetQMode.EMBEDDED);

	assertThat(this.context.getBeansOfType(EmbeddedJMS.class)).hasSize(1);
	org.hornetq.core.config.Configuration configuration = this.context
			.getBean(org.hornetq.core.config.Configuration.class);
	assertThat(configuration.isPersistenceEnabled()).isFalse();
	assertThat(configuration.isSecurityEnabled()).isFalse();

	HornetQConnectionFactory connectionFactory = this.context
			.getBean(HornetQConnectionFactory.class);
	assertInVmConnectionFactory(connectionFactory);
}

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

示例2: embeddedConnectionFactory

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Test
public void embeddedConnectionFactory() {
	load(EmptyConfiguration.class, "spring.hornetq.mode:embedded");

	HornetQProperties properties = this.context.getBean(HornetQProperties.class);
	assertEquals(HornetQMode.EMBEDDED, properties.getMode());

	assertEquals(1, this.context.getBeansOfType(EmbeddedJMS.class).size());
	org.hornetq.core.config.Configuration configuration = this.context
			.getBean(org.hornetq.core.config.Configuration.class);
	assertFalse("Persistence disabled by default",
			configuration.isPersistenceEnabled());
	assertFalse("Security disabled by default", configuration.isSecurityEnabled());

	HornetQConnectionFactory connectionFactory = this.context
			.getBean(HornetQConnectionFactory.class);
	assertInVmConnectionFactory(connectionFactory);
}

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

示例3: embeddedConnectionFactoryByDefault

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Test
public void embeddedConnectionFactoryByDefault() {
	// No mode is specified
	load(EmptyConfiguration.class);

	assertEquals(1, this.context.getBeansOfType(EmbeddedJMS.class).size());
	org.hornetq.core.config.Configuration configuration = this.context
			.getBean(org.hornetq.core.config.Configuration.class);
	assertFalse("Persistence disabled by default",
			configuration.isPersistenceEnabled());
	assertFalse("Security disabled by default", configuration.isSecurityEnabled());

	HornetQConnectionFactory connectionFactory = this.context
			.getBean(HornetQConnectionFactory.class);
	assertInVmConnectionFactory(connectionFactory);
}

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

示例4: hornetQServer

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Bean(initMethod = "start", destroyMethod = "stop")
@ConditionalOnMissingBean
public EmbeddedJMS hornetQServer(org.hornetq.core.config.Configuration configuration,
		JMSConfiguration jmsConfiguration) {
	EmbeddedJMS server = new EmbeddedJMS();
	customize(configuration);
	server.setConfiguration(configuration);
	server.setJmsConfiguration(jmsConfiguration);
	server.setRegistry(new HornetQNoOpBindingRegistry());
	return server;
}

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

示例5: embeddedConnectionFactoryByDefault

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Test
public void embeddedConnectionFactoryByDefault() {
	// No mode is specified
	load(EmptyConfiguration.class);

	assertThat(this.context.getBeansOfType(EmbeddedJMS.class)).hasSize(1);
	org.hornetq.core.config.Configuration configuration = this.context
			.getBean(org.hornetq.core.config.Configuration.class);
	assertThat(configuration.isPersistenceEnabled()).isFalse();
	assertThat(configuration.isSecurityEnabled()).isFalse();

	HornetQConnectionFactory connectionFactory = this.context
			.getBean(HornetQConnectionFactory.class);
	assertInVmConnectionFactory(connectionFactory);
}

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

示例6: nativeConnectionFactoryIfEmbeddedServiceDisabledExplicitly

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Test
public void nativeConnectionFactoryIfEmbeddedServiceDisabledExplicitly() {
	// No mode is specified
	load(EmptyConfiguration.class, "spring.hornetq.embedded.enabled:false");

	assertThat(this.context.getBeansOfType(EmbeddedJMS.class)).isEmpty();

	HornetQConnectionFactory connectionFactory = this.context
			.getBean(HornetQConnectionFactory.class);
	assertNettyConnectionFactory(connectionFactory, "localhost", 5445);
}

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

示例7: embeddedConnectionFactoryEvenIfEmbeddedServiceDisabled

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Test
public void embeddedConnectionFactoryEvenIfEmbeddedServiceDisabled() {
	// No mode is specified
	load(EmptyConfiguration.class, "spring.hornetq.mode:embedded",
			"spring.hornetq.embedded.enabled:false");

	assertThat(this.context.getBeansOfType(EmbeddedJMS.class)).isEmpty();

	HornetQConnectionFactory connectionFactory = this.context
			.getBean(HornetQConnectionFactory.class);
	assertInVmConnectionFactory(connectionFactory);
}

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

示例8: nativeConnectionFactoryIfEmbeddedServiceDisabledExplicitly

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Test
public void nativeConnectionFactoryIfEmbeddedServiceDisabledExplicitly() {
	// No mode is specified
	load(EmptyConfiguration.class, "spring.hornetq.embedded.enabled:false");

	assertEquals(0, this.context.getBeansOfType(EmbeddedJMS.class).size());

	HornetQConnectionFactory connectionFactory = this.context
			.getBean(HornetQConnectionFactory.class);
	assertNettyConnectionFactory(connectionFactory, "localhost", 5445);
}

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

示例9: embeddedConnectionFactorEvenIfEmbeddedServiceDisabled

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Test
public void embeddedConnectionFactorEvenIfEmbeddedServiceDisabled() {
	// No mode is specified
	load(EmptyConfiguration.class, "spring.hornetq.mode:embedded",
			"spring.hornetq.embedded.enabled:false");

	assertEquals(0, this.context.getBeansOfType(EmbeddedJMS.class).size());

	HornetQConnectionFactory connectionFactory = this.context
			.getBean(HornetQConnectionFactory.class);
	assertInVmConnectionFactory(connectionFactory);
}

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

示例10: initialize

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Override
public void initialize() {
    super.initialize();
    if (_startEmbedded) {
        _embeddedJMS = new EmbeddedJMS();
        _embeddedJMS.setConfigResourcePath(HORNETQ_CONF_FILE);
        _embeddedJMS.setJmsConfigResourcePath(HORNETQ_JMS_CONF_FILE);
        try {
            _embeddedJMS.setRegistry(new JndiBindingRegistry());
            _embeddedJMS.start();
        } catch (final Exception e) {
            throw new RuntimeException(e);
        }
    }
}

开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:16，代码来源:HornetQMixIn.java

示例11: HornetQHealthIndicator

import org.hornetq.jms.server.embedded.EmbeddedJMS; //导入依赖的package包/类
@Autowired
public HornetQHealthIndicator(ClientSessionFactory sf, EmbeddedJMS embeddedJMS, HornetQHealthConfigurationProperties properties) {
    this.sf = sf;
    this.properties = properties;
    this.queueNames = embeddedJMS.getHornetQServer().getHornetQServerControl().getQueueNames();
}

开发者ID:mdoninger，项目名称:spring-boot-health-indicator-sample，代码行数:7，代码来源:HornetQHealthIndicator.java

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