Package org.apache.activemq.partition

Examples of org.apache.activemq.partition.PartitionBrokerPlugin

28
29
30
31
32
33
34
35
36
37
38
39
    public void testCreatePartitionBroker() throws Exception {

        BrokerService broker = BrokerFactory.createBroker("xbean:activemq-partition.xml");
        assertEquals(1, broker.getPlugins().length);
        PartitionBrokerPlugin plugin = (PartitionBrokerPlugin)broker.getPlugins()[0];
        Partitioning config = plugin.getConfig();
        assertEquals(2,  config.getBrokers().size());

        Object o;
        String json = "{\n" +
        "  \"by_client_id\":{\n" +
View Full Code Here
TOP

Related Classes of org.apache.activemq.partition.PartitionBrokerPlugin

  • org.apache.activemq.broker.partition.SpringPartitionBrokerTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.