@Test
    public void testOneMasterOneSlaveNProducerNConsumer() throws Exception {
        // start slave
        this.slave = this.startEnhanceBroker("gregor_server1", true, true, this.getSlaveProperties());
        // start master
        this.master = this.startEnhanceBroker("samsa_server1", true, true, this.getMasterProperties());
        try {
            this.create_nProducer(10);
            this.sendMessage_nProducer(100, "testOneMasterOneSlaveNProducerNConsumer", this.topic, 10);
            this.subscribe_nConsumer(this.topic, 1024 * 1024, 100, 10, 10);
            // this.subscribe(this.topic, 1024 * 1024, 100);
        }
        finally {
            Utils.shutdown(this.producerList);
            Utils.shutdown(this.consumerList);
        }
    }
@author boyan(boyan@taobao.com)
@date 2011-12-29
metamorphosis-integration-test/src/test/java/com/taobao/meta/test/gregor/GregorMasterSlaveTest.java