本文整理了Java中org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.getStaticConnectors()
方法的一些代码示例,展示了ActiveMQConnectionFactory.getStaticConnectors()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ActiveMQConnectionFactory.getStaticConnectors()
方法的具体详情如下:
包路径:org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory
类名称:ActiveMQConnectionFactory
方法名:getStaticConnectors
暂无
代码示例来源:origin: wildfly/wildfly
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
return InVMServerLocatorSchema.getUri(bean.getStaticConnectors());
}
}
代码示例来源:origin: wildfly/wildfly
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
String query = BeanSupport.getData(null, bean);
TransportConfiguration[] staticConnectors = bean.getStaticConnectors();
return TCPServerLocatorSchema.getURI(query, staticConnectors);
}
}
代码示例来源:origin: apache/activemq-artemis
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
return InVMServerLocatorSchema.getUri(bean.getStaticConnectors());
}
}
代码示例来源:origin: apache/activemq-artemis
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
return InVMServerLocatorSchema.getUri(bean.getStaticConnectors());
}
}
代码示例来源:origin: org.apache.activemq/artemis-jms-client-all
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
return InVMServerLocatorSchema.getUri(bean.getStaticConnectors());
}
}
代码示例来源:origin: org.jboss.eap/wildfly-client-all
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
return InVMServerLocatorSchema.getUri(bean.getStaticConnectors());
}
}
代码示例来源:origin: apache/activemq-artemis
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
String query = BeanSupport.getData(null, bean);
TransportConfiguration[] staticConnectors = bean.getStaticConnectors();
return TCPServerLocatorSchema.getURI(query, staticConnectors);
}
}
代码示例来源:origin: apache/activemq-artemis
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
String query = BeanSupport.getData(null, bean);
TransportConfiguration[] staticConnectors = bean.getStaticConnectors();
return TCPServerLocatorSchema.getURI(query, staticConnectors);
}
}
代码示例来源:origin: org.apache.activemq/artemis-jms-client-all
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
String query = BeanSupport.getData(null, bean);
TransportConfiguration[] staticConnectors = bean.getStaticConnectors();
return TCPServerLocatorSchema.getURI(query, staticConnectors);
}
}
代码示例来源:origin: org.jboss.eap/wildfly-client-all
@Override
protected URI internalNewURI(ActiveMQConnectionFactory bean) throws Exception {
String query = BeanSupport.getData(null, bean);
TransportConfiguration[] staticConnectors = bean.getStaticConnectors();
return TCPServerLocatorSchema.getURI(query, staticConnectors);
}
}
代码示例来源:origin: apache/activemq-artemis
@Test
public void testConnectionFactoryStatic1() throws Exception {
createStaticFactory(true);
cf = (ActiveMQConnectionFactory) namingContext.lookup("/MyConnectionFactory");
// apparently looking up the connection factory with the org.apache.activemq.artemis.jms.tests.tools.container.InVMInitialContextFactory
// is not enough to actually serialize it so we serialize it manually
byte[] x = serialize(cf);
ActiveMQConnectionFactory y = deserialize(x, ActiveMQConnectionFactory.class);
checkEquals(cf, y);
Assert.assertEquals(cf.isHA(), y.isHA());
TransportConfiguration[] staticConnectors = y.getStaticConnectors();
Assert.assertEquals(staticConnectors.length, 2);
TransportConfiguration tc0 = cf.getStaticConnectors()[0];
TransportConfiguration y0 = y.getStaticConnectors()[0];
Map<String, Object> ctParams = tc0.getParams();
Map<String, Object> y0Params = y0.getParams();
Assert.assertEquals(ctParams.size(), y0Params.size());
for (String key : y0Params.keySet()) {
Assert.assertEquals(ctParams.get(key), y0Params.get(key));
}
}
代码示例来源:origin: apache/activemq-artemis
final double retryIntervalMultiplier,
final int reconnectAttempts) {
TransportConfiguration[] cfStaticConnectors = cf.getStaticConnectors();
if (staticConnectors == null) {
Assert.assertNull(staticConnectors);
代码示例来源:origin: apache/activemq-artemis
cf.getStaticConnectors();
cf.getClientID();
cf.getClientFailureCheckPeriod();
内容来源于网络,如有侵权,请联系作者删除!