org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.getStaticConnectors()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(4.3k)|赞(0)|评价(0)|浏览(68)

本文整理了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

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();

相关文章

微信公众号

最新文章

更多

ActiveMQConnectionFactory类方法