20.11.3.4. 为 Core API 配置发现
如果您使用 Core API 来直接实例化
ClientSessionFactory,那么在创建会话工厂时您可以直接指定发现组参数:
final String groupAddress = "231.7.7.7"; final int groupPort = 9876; ServerLocator factory = HornetQClient.createServerLocatorWithHA(new DiscoveryGroupConfiguration(groupAddress, groupPort, new UDPBroadcastGroupConfiguration(groupAddress, groupPort, null, -1)))); ClientSessionFactory factory = locator.createSessionFactory(); ClientSession session1 = factory.createSession(); ClientSession session2 = factory.createSession();
refresh-timeout 属性的默认值可以通过 setter 方法 setDiscoveryRefreshTimeout() 在 DiscoveryGroupConfiguration 上进行设置。在创建会话前,您可以使用会话工厂的 DiscoveryGroupConfiguration 上的setDiscoveryInitialWaitTimeout() 方法等待指定的时间。