Implement Client-Side Load Balancing using Core
If you're using the core API, you can set the load balancing policy directly on the ClientSessionFactory instance you are using: ClientSessionFactory factory = HornetQClient.createClientSessionFactory(...); factory.setLoadBalancingPolicyClassName("com.acme.MyLoadBalancingPolicy"); The set of servers over which the factory load balances can be determined in one of two ways: Specifying servers explicitly Using discovery.