本文整理汇总了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；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论