Method MQManager

ZezeJava/ZezeJava/src/main/java/Zeze/MQ/MQManager.java:41–50

(String home, String configXml)

    private final ConcurrentHashMap<String, MQPartition> queues = new ConcurrentHashMap<>();

    public MQManager(String home, String configXml) throws RocksDBException {
        this.home = home;
        this.rocksDatabase = new RocksDatabase(this.home);
        var config = Config.load(configXml);
        config.parseCustomize(this.mqConfig);
        proxyServer = new ProxyServer(config, mqConfig.getRpcTimeout());
        masterService = new Service(config, proxyServer);
        masterAgent = new MasterAgent(config, masterService, this::createPartition);
        RegisterProtocols(proxyServer);
    }

    public String getHome() {
        return home;