Package com.taobao.metamorphosis.server.assembly

Examples of com.taobao.metamorphosis.server.assembly.MetaMorphosisBroker.start()

188
189
190
191
192
193
194
195
196
197
198
            this.broker.init(metaBroker, props);
            // recover����ʱ�Ȳ�������zk
            assertFalse(metaBroker.getBrokerZooKeeper().getZkConfig().zkEnable);

            // ������meta broker
            metaBroker.start();
            // ��ʼrecover
            this.broker.start();

            // ȷ���Ƿ�ȫ����ƫ�ɹ�
            final String consumerId = "SamsaMasterBrokerUnitTest";
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
        final MetaMorphosisBroker broker = new MetaMorphosisBroker(metaConfig);
        if (isClearConsumerInfo) {
            Utils.clearConsumerInfoInZk(broker.getBrokerZooKeeper().getZkClient(), broker.getBrokerZooKeeper()
                .getMetaZookeeper());
        }
        broker.start();
        this.brokers.add(broker);
        return broker;
    }

View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
    public static void main(final String[] args) {
        final String configFilePath = getConfigFilePath(args);
        final MetaConfig metaConfig = getMetaConfig(configFilePath);
        final MetaMorphosisBroker server = new MetaMorphosisBroker(metaConfig);
        server.start();

    }


    static MetaConfig getMetaConfig(final String configFilePath) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.