本文整理汇总了Java中org.hornetq.core.remoting.impl.netty.NettyConnectorFactory类的典型用法代码示例。如果您正苦于以下问题：Java NettyConnectorFactory类的具体用法？Java NettyConnectorFactory怎么用？Java NettyConnectorFactory使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
NettyConnectorFactory类属于org.hornetq.core.remoting.impl.netty包，在下文中一共展示了NettyConnectorFactory类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: hornetQMessageListenerContainer
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
@Bean
public MessageListenerContainer hornetQMessageListenerContainer() {
Map<String, Object> map = new HashMap<String, Object>();
map.put(TransportConstants.HOST_PROP_NAME, hornetq_host);
map.put(TransportConstants.PORT_PROP_NAME, hornetq_port);
TransportConfiguration transportConfiguration =new TransportConfiguration(
NettyConnectorFactory.class.getName(), map);
HornetQConnectionFactory hornetQConnectionFactory = HornetQJMSClient.createConnectionFactoryWithoutHA(
JMSFactoryType.CF, transportConfiguration);
DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
container.setConnectionFactory((ConnectionFactory) hornetQConnectionFactory);
container.setDestination(HornetQJMSClient.createTopic(IMConstant.GATEWAY_USERREGISTER_TOPIC));
container.setPubSubDomain(true);
container.setPubSubNoLocal(true);
container.setMessageListener(userRegisterListener);
container.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
return container;
}
开发者ID:projectsrepos，项目名称:jim，代码行数:21，代码来源:GatewayUserRegisterConfig.java
示例2: isAnotherInstanceRunning
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
/**
* check if another instance of ioFabric is running
*
* @return boolean
*/
private static boolean isAnotherInstanceRunning() {
Map<String, Object> connectionParams = new HashMap<>();
connectionParams.put("port", 55555);
connectionParams.put("host", "localhost");
ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(
new TransportConfiguration(NettyConnectorFactory.class.getName(), connectionParams));
try {
sf = serverLocator.createSessionFactory();
} catch (Exception e) {
return false;
}
return true;
}
开发者ID:iotracks，项目名称:iofabric，代码行数:21，代码来源:Start.java
示例3: fromAuthority
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
public static TransportConfiguration fromAuthority(@NonNull String authority) {
String[] hostAndPort = authority.split(":");
checkArgument(hostAndPort.length == 2);
checkArgument(!hostAndPort[0].isEmpty());
checkArgument(!hostAndPort[1].isEmpty());
return new TransportConfiguration(NettyConnectorFactory.class.getName(), ImmutableMap.of(
TransportConstants.HOST_PROP_NAME, hostAndPort[0],
TransportConstants.PORT_PROP_NAME, hostAndPort[1]));
}
开发者ID:Mercateo，项目名称:mercateo-spring-boot-starter-hornetq-cluster，代码行数:10，代码来源:TransportConfigurations.java
示例4: fromAuthorityGoodCase
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
@Test
public void fromAuthorityGoodCase() throws Exception {
TransportConfiguration transportConfiguration = TransportConfigurations.fromAuthority(
"somehost:12345");
assertEquals("somehost", transportConfiguration.getParams().get("host"));
assertEquals("12345", transportConfiguration.getParams().get("port"));
assertEquals(NettyConnectorFactory.class.getName(), transportConfiguration
.getFactoryClassName());
}
开发者ID:Mercateo，项目名称:mercateo-spring-boot-starter-hornetq-cluster，代码行数:10，代码来源:TransportConfigurations0Test.java
示例5: createNativeConnectionFactory
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
private <T extends HornetQConnectionFactory> T createNativeConnectionFactory(
Class<T> factoryClass) throws Exception {
Map<String, Object> params = new HashMap<String, Object>();
params.put(TransportConstants.HOST_PROP_NAME, this.properties.getHost());
params.put(TransportConstants.PORT_PROP_NAME, this.properties.getPort());
TransportConfiguration transportConfiguration = new TransportConfiguration(
NettyConnectorFactory.class.getName(), params);
Constructor<T> constructor = factoryClass.getDeclaredConstructor(
HornetQProperties.class, boolean.class, TransportConfiguration[].class);
return BeanUtils.instantiateClass(constructor, this.properties, false,
new TransportConfiguration[] { transportConfiguration });
}
开发者ID:vikrammane23，项目名称:https-github.com-g0t4-jenkins2-course-spring-boot，代码行数:13，代码来源:HornetQConnectionFactoryFactory.java
示例6: assertNettyConnectionFactory
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
private TransportConfiguration assertNettyConnectionFactory(
HornetQConnectionFactory connectionFactory, String host, int port) {
TransportConfiguration transportConfig = getSingleTransportConfiguration(
connectionFactory);
assertThat(transportConfig.getFactoryClassName())
.isEqualTo(NettyConnectorFactory.class.getName());
assertThat(transportConfig.getParams().get("host")).isEqualTo(host);
assertThat(transportConfig.getParams().get("port")).isEqualTo(port);
return transportConfig;
}
开发者ID:vikrammane23，项目名称:https-github.com-g0t4-jenkins2-course-spring-boot，代码行数:11，代码来源:HornetQAutoConfigurationTests.java
示例7: createNativeConnectionFactory
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
private <T extends HornetQConnectionFactory> T createNativeConnectionFactory(
Class<T> factoryClass) throws Exception {
Map<String, Object> params = new HashMap<String, Object>();
params.put(TransportConstants.HOST_PROP_NAME, this.properties.getHost());
params.put(TransportConstants.PORT_PROP_NAME, this.properties.getPort());
TransportConfiguration transportConfiguration = new TransportConfiguration(
NettyConnectorFactory.class.getName(), params);
Constructor<T> constructor = factoryClass.getConstructor(boolean.class,
TransportConfiguration[].class);
return constructor.newInstance(false,
new TransportConfiguration[] { transportConfiguration });
}
开发者ID:philwebb，项目名称:spring-boot-concourse，代码行数:13，代码来源:HornetQConnectionFactoryFactory.java
示例8: assertNettyConnectionFactory
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
private TransportConfiguration assertNettyConnectionFactory(
HornetQConnectionFactory connectionFactory, String host, int port) {
TransportConfiguration transportConfig = getSingleTransportConfiguration(
connectionFactory);
assertEquals(NettyConnectorFactory.class.getName(),
transportConfig.getFactoryClassName());
assertEquals(host, transportConfig.getParams().get("host"));
assertEquals(port, transportConfig.getParams().get("port"));
return transportConfig;
}
开发者ID:Nephilim84，项目名称:contestparser，代码行数:11，代码来源:HornetQAutoConfigurationTests.java
示例9: createClientSession
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
/**
* Close the existing ClientSession if exists and create new one.
* @return ClientSession instance
*/
public ClientSession createClientSession() {
closeSession(_clientSession);
try {
if (_serverLocator == null || _clientSessionFactory == null) {
if (_startEmbedded) {
_serverLocator = HornetQClient.createServerLocatorWithoutHA(getTransports(getConfiguration()));
_clientSessionFactory = _serverLocator.createSessionFactory();
} else {
_serverLocator = HornetQClient.createServerLocatorWithoutHA(
new TransportConfiguration(NettyConnectorFactory.class.getName(), _transportParams));
_clientSessionFactory = _serverLocator.createSessionFactory();
}
}
_clientSession = _clientSessionFactory.createSession(_user,
_passwd,
false,
true,
true,
_serverLocator.isPreAcknowledge(),
_serverLocator.getAckBatchSize());
_clientSession.start();
return _clientSession;
} catch (Exception e) {
throw new RuntimeException(e);
}
}
开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:33，代码来源:HornetQMixIn.java
示例10: coreConfiguration
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
private Configuration coreConfiguration(AddressAndPort host) {
Configuration configuration = new ConfigurationImpl();
configuration.setPersistenceEnabled(false);
configuration.setJournalDirectory("build/data/journal");
configuration.setSecurityEnabled(false);
Map<String, Object> params = new HashMap<String, Object>();
params.put(TransportConstants.HOST_PROP_NAME, host.address());
params.put(TransportConstants.PORT_PROP_NAME, host.port());
configuration.getAcceptorConfigurations().add(new TransportConfiguration(NettyAcceptorFactory.class.getName(), params));
TransportConfiguration connectorConfig = new TransportConfiguration(NettyConnectorFactory.class.getName(), params);
configuration.getConnectorConfigurations().put("connector", connectorConfig);
return configuration;
}
开发者ID:signed，项目名称:in-memory-infrastructure，代码行数:14，代码来源:JmsServer.java
示例11: init
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; //导入依赖的package包/类
public void init() throws InitException {
Map<String, Object> connectionParams = new HashMap<>();
connectionParams.put(TransportConstants.HOST_PROP_NAME, getHost());
connectionParams.put(TransportConstants.PORT_PROP_NAME, getPort());
TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName(),
connectionParams);
factory = new HornetQJMSConnectionFactory(false,transportConfiguration);
try {
connection = factory.createConnection(getUser(),getPassword());
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
dest = (getDestType() == DestType.QUEUE) ? session.createQueue(getDestination()) : session.createTopic(getDestination());
producer = session.createProducer(dest);
connection.start();
} catch (JMSException e) {
throw new InitException(e.fillInStackTrace());
}
}
开发者ID:matthiaskaiser，项目名称:jmet，代码行数:29，代码来源:HornetQTarget.java
注：本文中的org.hornetq.core.remoting.impl.netty.NettyConnectorFactory类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论